| commit | 76b54bfca4fe0a0b58427c2e5e3cf13490763afc | [log] [tgz] |
|---|---|---|
| author | Yuta HIGUCHI <y-higuchi@onlab.us> | Fri Nov 07 01:56:55 2014 -0800 |
| committer | Yuta HIGUCHI <y-higuchi@onlab.us> | Fri Nov 07 01:56:55 2014 -0800 |
| tree | 12559e934267834465bbd799bd2a83f447811f15 | |
| parent | 813fb90b8dc12367ac3f2d7497c7a319496f4709 [diff] [blame] |
ClusterMessagingProtocolServer: start listening at correct timing Change-Id: Ie8ed1894ae16c41242aee861440174f011dd689b
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 849ad17..1e47a00 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
@@ -166,10 +166,15 @@ @Override public void addSubscriber(MessageSubject subject, - ClusterMessageHandler subscriber) { + ClusterMessageHandler subscriber) { messagingService.registerHandler(subject.value(), new InternalClusterMessageHandler(subscriber)); } + @Override + public void removeSubscriber(MessageSubject subject) { + messagingService.unregisterHandler(subject.value()); + } + private final class InternalClusterMessageHandler implements MessageHandler { private final ClusterMessageHandler handler;