Yuta HIGUCHI

deactivate NettyMessagingService

Change-Id: I59a437908570c9acc2776c2b0deedb869cf953e2
...@@ -85,7 +85,6 @@ public class ClusterCommunicationManager ...@@ -85,7 +85,6 @@ public class ClusterCommunicationManager
85 try { 85 try {
86 netty.activate(); 86 netty.activate();
87 } catch (Exception e) { 87 } catch (Exception e) {
88 - // TODO Auto-generated catch block
89 log.error("NettyMessagingService#activate", e); 88 log.error("NettyMessagingService#activate", e);
90 } 89 }
91 messagingService = netty; 90 messagingService = netty;
...@@ -95,6 +94,12 @@ public class ClusterCommunicationManager ...@@ -95,6 +94,12 @@ public class ClusterCommunicationManager
95 @Deactivate 94 @Deactivate
96 public void deactivate() { 95 public void deactivate() {
97 // TODO: cleanup messageingService if needed. 96 // TODO: cleanup messageingService if needed.
97 + // FIXME: workaround until it becomes a service.
98 + try {
99 + ((NettyMessagingService) messagingService).deactivate();
100 + } catch (Exception e) {
101 + log.error("NettyMessagingService#deactivate", e);
102 + }
98 log.info("Stopped"); 103 log.info("Stopped");
99 } 104 }
100 105
......