Madan Jampani | 890bc35 | 2014-10-01 22:35:29 -0700 | [diff] [blame] | 1 | package org.onlab.onos.store.messaging.impl; |
| 2 | |
| 3 | import java.util.concurrent.TimeUnit; |
| 4 | |
Madan Jampani | 890bc35 | 2014-10-01 22:35:29 -0700 | [diff] [blame] | 5 | import org.onlab.onos.store.messaging.Endpoint; |
| 6 | import org.onlab.onos.store.messaging.Response; |
| 7 | |
| 8 | public final class SimpleClient { |
| 9 | private SimpleClient() {} |
| 10 | |
| 11 | public static void main(String... args) throws Exception { |
| 12 | NettyMessagingService messaging = new TestNettyMessagingService(9081); |
| 13 | messaging.activate(); |
| 14 | |
| 15 | messaging.sendAsync(new Endpoint("localhost", 8080), "simple", "Hello World"); |
| 16 | Response<String> response = messaging.sendAndReceive(new Endpoint("localhost", 8080), "echo", "Hello World"); |
| 17 | System.out.println("Got back:" + response.get(2, TimeUnit.SECONDS)); |
| 18 | } |
| 19 | |
| 20 | public static class TestNettyMessagingService extends NettyMessagingService { |
| 21 | public TestNettyMessagingService(int port) throws Exception { |
| 22 | super(port); |
Madan Jampani | e4ff21b | 2014-10-02 15:17:32 -0700 | [diff] [blame] | 23 | Serializer serializer = new KryoSerializer(); |
| 24 | this.serializer = serializer; |
Madan Jampani | 890bc35 | 2014-10-01 22:35:29 -0700 | [diff] [blame] | 25 | } |
| 26 | } |
| 27 | } |