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);