commit c3e6270481774408c03b08d1ea26ebd2f3f8976c
author Jian Li <pyguni@gmail.com> Fri Mar 03 02:46:43 2017 +0900
committer Thomas Vachuska <tom@onlab.us> Fri Mar 03 16:49:15 2017 +0000
tree 3b47439f3dc1a7e414ca1ad7d5e79471bd39c1cf
parent 04c461d5674493aac1d5e096803e43070eebf8db

Bugfix: Remove duplicated subscriber reg. for receiving async msg

Change-Id: Idecde74a4d8e2586d33350168b1d6432204671e5

core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
index 699a4d3..f451712 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
@@ -337,8 +337,6 @@
         clusterCommunicator.addSubscriber(
                 REMOVE_FLOW_ENTRY, serializer::decode, this::removeFlowRuleInternal, serializer::encode, executor);
         clusterCommunicator.addSubscriber(
-                REMOVE_FLOW_ENTRY, serializer::decode, this::removeFlowRuleInternal, serializer::encode, executor);
-        clusterCommunicator.addSubscriber(
                 FLOW_TABLE_BACKUP, serializer::decode, flowTable::onBackupReceipt, serializer::encode, executor);
     }