| commit | f8d572f1aeeb53084ab3766163f34c715a872da0 | [log] [tgz] |
|---|---|---|
| author | Madan Jampani <madan@onlab.us> | Tue Aug 25 12:14:43 2015 -0700 |
| committer | Gerrit Code Review <gerrit@onlab.us> | Tue Aug 25 19:47:28 2015 +0000 |
| tree | 61ef5733b01f3709c3bf2fcef6fbd3b2229112bc | |
| parent | 4f87faae8225eaeef2ca00ffe403332e33eb82cc [diff] |
ONOS-2725: Fix subscriber registration for link inject request Change-Id: I56a651a561a4fe59161ad00dbd28e28fad6731c9
diff --git a/core/store/dist/src/main/java/org/onosproject/store/link/impl/ECLinkStore.java b/core/store/dist/src/main/java/org/onosproject/store/link/impl/ECLinkStore.java index c1fef07..678e242 100644 --- a/core/store/dist/src/main/java/org/onosproject/store/link/impl/ECLinkStore.java +++ b/core/store/dist/src/main/java/org/onosproject/store/link/impl/ECLinkStore.java
@@ -148,6 +148,7 @@ clusterCommunicator.addSubscriber(LINK_INJECT_MESSAGE, SERIALIZER::decode, this::injectLink, + SERIALIZER::encode, SharedExecutors.getPoolThreadExecutor()); linkDescriptions.addListener(linkTracker);