package mina;

import java.net.*;
import java.nio.charset.*;
import org.apache.mina.core.future.*;
import org.apache.mina.filter.codec.*;
import org.apache.mina.filter.codec.textline.*;
import org.apache.mina.filter.logging.*;
import org.apache.mina.transport.socket.nio.*;

public class MinaTimeClient {
	
	public static final long TIMEOUT = 30;
	
	public static void configClient(NioSocketConnector connector) {
		connector.getFilterChain().addLast("logger", new LoggingFilter());
		connector.getFilterChain().addLast("codec",
				new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));
		
		connector.setConnectTimeoutMillis(TIMEOUT);
		connector.setHandler(new TimeClientHandler());
	}
	
	public static void main(String[] args) {
		NioSocketConnector connector = new NioSocketConnector();
		configClient(connector);
		
		ConnectFuture cf = connector.connect(new InetSocketAddress("127.0.0.1", 9123));
		cf.awaitUninterruptibly();
		System.out.println("connected: " + cf.isConnected());
		if (!cf.isConnected()) {
			connector.dispose();
			return;
		}
		
		cf.getSession().write("Hi Server!");
		cf.getSession().write("quit");
		
		cf.getSession().getCloseFuture().awaitUninterruptibly();
		connector.dispose();
	}
}