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/messaging/impl/SimpleClient.java b/core/store/dist/src/main/java/org/onlab/onos/store/messaging/impl/SimpleClient.java
new file mode 100644
index 0000000..95753e7
--- /dev/null
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/messaging/impl/SimpleClient.java
@@ -0,0 +1,29 @@
+package org.onlab.onos.store.messaging.impl;
+
+import java.util.concurrent.TimeUnit;
+
+import org.onlab.onos.store.cluster.impl.MessageSerializer;
+import org.onlab.onos.store.messaging.Endpoint;
+import org.onlab.onos.store.messaging.Response;
+
+public final class SimpleClient {
+ private SimpleClient() {}
+
+ public static void main(String... args) throws Exception {
+ NettyMessagingService messaging = new TestNettyMessagingService(9081);
+ messaging.activate();
+
+ messaging.sendAsync(new Endpoint("localhost", 8080), "simple", "Hello World");
+ Response<String> response = messaging.sendAndReceive(new Endpoint("localhost", 8080), "echo", "Hello World");
+ System.out.println("Got back:" + response.get(2, TimeUnit.SECONDS));
+ }
+
+ public static class TestNettyMessagingService extends NettyMessagingService {
+ public TestNettyMessagingService(int port) throws Exception {
+ super(port);
+ MessageSerializer mgr = new MessageSerializer();
+ mgr.activate();
+ this.serializationService = mgr;
+ }
+ }
+}