commit 8158314c8fea5bea68b201c426c2a5c4b45f03c3
author tom <tom@onlab.us> Tue Sep 30 01:40:29 2014 -0700
committer tom <tom@onlab.us> Tue Sep 30 01:40:29 2014 -0700
tree 10481ac7bb1ff437f315637077943db26c9c5a93
parent 4ee8bae6754cb7926279e6d987022bf85db11e32

Further simplified the store & connection manager relationship.

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

diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubscriber.java b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubscriber.java
index 6b78fec..68cd83c 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubscriber.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/cluster/messaging/MessageSubscriber.java
@@ -1,5 +1,7 @@
 package org.onlab.onos.store.cluster.messaging;
 
+import org.onlab.onos.cluster.NodeId;
+
 /**
  * Represents a message consumer.
  */
@@ -8,8 +10,9 @@
     /**
      * Receives the specified cluster message.
      *
-     * @param message message to be received
+     * @param message    message to be received
+     * @param fromNodeId node from which the message was received
      */
-    void receive(ClusterMessage message);
+    void receive(ClusterMessage message, NodeId fromNodeId);
 
 }