commit 6c6fb9c65d98fe50c41fa77f1b2f9eae08b663bf
author Yuta HIGUCHI <y-higuchi@onlab.us> Fri Oct 31 20:21:15 2014 -0700
committer Yuta HIGUCHI <y-higuchi@onlab.us> Fri Oct 31 23:21:39 2014 -0700
tree 809fb51aeb736c212de22719e7741b5c985705d9
parent d26354db11a49298c42250004ac70ddcec9a8757

deactivate NettyMessagingService

Change-Id: I59a437908570c9acc2776c2b0deedb869cf953e2

core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java

diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
index 540de77..79612c9 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/impl/ClusterCommunicationManager.java
@@ -85,7 +85,6 @@
         try {
             netty.activate();
         } catch (Exception e) {
-            // TODO Auto-generated catch block
             log.error("NettyMessagingService#activate", e);
         }
         messagingService = netty;
@@ -95,6 +94,12 @@
     @Deactivate
     public void deactivate() {
         // TODO: cleanup messageingService if needed.
+        // FIXME: workaround until it becomes a service.
+        try {
+            ((NettyMessagingService) messagingService).deactivate();
+        } catch (Exception e) {
+            log.error("NettyMessagingService#deactivate", e);
+        }
         log.info("Stopped");
     }