package clientserver;

import java.io.IOException;

public class ClientServerTest {
	static final int PORT = 10451;
	public static void main(String[] args) throws IOException {
		new Server(new DoublingServer(), PORT).start();
		new ClientManager("Ken's Client", new DoublingClient(), "localhost", PORT).start();
	}
}

class DoublingServer extends AbstractServerBehavior {
	public synchronized void messageReceived(Object message, ClientHandler client) {
		client.sendMessage(new Long (((Long) message).longValue() * 2));
	}
}

class DoublingClient extends AbstractClientBehavior {
	public void messageReceived(Object message) {
		System.out.println("received: "+message);
		clientManager.sendMessage(message);
	}
	public void run() {
		clientManager.sendMessage(new Long(2));
	}
}