commit | 890bc35e69766ff4ab5fd1a16e0e5c38f9603a16 | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan@onlab.us> | Wed Oct 01 22:35:29 2014 -0700 |
committer | Madan Jampani <madan@onlab.us> | Wed Oct 01 22:35:29 2014 -0700 |
tree | 51a600aaf40919ac51578d299fb511bb926830a3 | |
parent | e1d923802441814016999ab4e2015d9b9d058dd7 [diff] [blame] |
Added Netty based messaging. Updated cluster management to use Netty based messaging
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 68cd83c..666ac6d 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
@@ -13,6 +13,6 @@ * @param message message to be received * @param fromNodeId node from which the message was received */ - void receive(ClusterMessage message, NodeId fromNodeId); + void receive(Object messagePayload, NodeId fromNodeId); }