| 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; |
| } |
| } |
| } |