#1128 Reused existing product processor instance, removed duplicates,…

… removed TODOs
subutai-io · Sep 19, 2017 · 4a093db · 4a093db
1 parent 809db09
commit 4a093db
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/...anager/hub-manager-impl/src/main/java/io/subutai/core/hubmanager/impl/HubManagerImpl.java b/...anager/hub-manager-impl/src/main/java/io/subutai/core/hubmanager/impl/HubManagerImpl.java
@@ -153,6 +153,8 @@ public class HubManagerImpl implements HubManager, HostListener
 
     private ContainerMetricsService containerMetricsService;
 
+    private ProductProcessor productProcessor;
+
 
     public HubManagerImpl( DaoManager daoManager )
     {
@@ -260,7 +262,7 @@ private void initHeartbeatProcessors()
 
         StateLinkProcessor hubEnvironmentProcessor = new HubEnvironmentProcessor( ctx );
 
-        ProductProcessor productProcessor = new ProductProcessor( configManager, this.hubEventListeners, restClient );
+        productProcessor = new ProductProcessor( configManager, this.hubEventListeners, restClient );
 
         AppScaleProcessor appScaleProcessor = new AppScaleProcessor( new AppScaleManager( peerManager ), restClient );
 
@@ -479,9 +481,6 @@ public void installPlugin( String url, String name, String uid ) throws HubManag
 
             if ( isRegisteredWithHub() )
             {
-                //TODO use already existing this.productProcessor
-                ProductProcessor productProcessor =
-                        new ProductProcessor( this.configManager, this.hubEventListeners, this.restClient );
                 PeerProductDataDto peerProductDataDto = new PeerProductDataDto();
                 peerProductDataDto.setProductId( uid );
                 peerProductDataDto.setState( PeerProductDataDto.State.INSTALLED );
@@ -523,9 +522,6 @@ public void uninstallPlugin( final String name, final String uid )
 
         if ( isRegisteredWithHub() )
         {
-            //TODO use already existing this.productProcessor
-            ProductProcessor productProcessor =
-                    new ProductProcessor( this.configManager, this.hubEventListeners, this.restClient );
             PeerProductDataDto peerProductDataDto = new PeerProductDataDto();
             peerProductDataDto.setProductId( uid );
             peerProductDataDto.setState( PeerProductDataDto.State.REMOVE );