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/SimpleServer.java b/core/store/dist/src/main/java/org/onlab/onos/store/messaging/impl/SimpleServer.java
new file mode 100644
index 0000000..1b331ba
--- /dev/null
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/messaging/impl/SimpleServer.java
@@ -0,0 +1,22 @@
+package org.onlab.onos.store.messaging.impl;
+
+import org.onlab.onos.store.cluster.impl.MessageSerializer;
+
+public final class SimpleServer {
+ private SimpleServer() {}
+
+ public static void main(String... args) throws Exception {
+ NettyMessagingService server = new TestNettyMessagingService();
+ server.activate();
+ server.registerHandler("simple", new LoggingHandler());
+ server.registerHandler("echo", new EchoHandler());
+ }
+
+ public static class TestNettyMessagingService extends NettyMessagingService {
+ protected TestNettyMessagingService() {
+ MessageSerializer mgr = new MessageSerializer();
+ mgr.activate();
+ this.serializationService = mgr;
+ }
+ }
+}