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