import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;

import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

public class MinaTimeServer
{
  private static final int PORT = 9123;

  public static void main( String[] args ) throws IOException
  {
      IoAcceptor acceptor = new NioSocketAcceptor();

      acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
      acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));

      acceptor.setHandler( new TimeServerHandler() );
      acceptor.getSessionConfig().setReadBufferSize( 2048 );
      acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
      acceptor.bind( new InetSocketAddress(PORT) );
  }
}

import java.util.Date;

import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;

public class TimeServerHandler extends IoHandlerAdapter
{
  @Override
      public void exceptionCaught( IoSession session, Throwable cause ) throws Exception
      {
          cause.printStackTrace();
      }

  @Override
      public void messageReceived( IoSession session, Object message ) throws Exception
      {
          String str = message.toString();
          if( str.trim().equalsIgnoreCase("quit") ) {
              session.close();
              return;
          }

          Date date = new Date();
          session.write( date.toString() );
          System.out.println("Message written...");
      }

  @Override
      public void sessionIdle( IoSession session, IdleStatus status ) throws Exception
      {
          System.out.println( "IDLE " + session.getIdleCount( status ));
      }
}

$telnet 127.0.0.1 9123

# Set root logger level to DEBUG and its only appender to A1.
log4j.rootLogger=DEBUG, A1

# A1 is set to be a ConsoleAppender.
log4j.appender.A1=org.apache.log4j.ConsoleAppender

# A1 uses PatternLayout.
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=%-4r [%t] %-5p %c{1} %x - %m%n

LoggingFilter loggingFilter = new LoggingFilter();
chain.addLast("logging", loggingFilter);

// Allocates a new buffer with a specific size, defining its type (direct or heap)
public static IoBuffer allocate(int capacity, boolean direct)

// Allocates a new buffer with a specific size
public static IoBuffer allocate(int capacity)

IoBuffer buffer = IoBuffer.allocate(8);
buffer.setAutoExpand(true);

buffer.putString("12345678", encoder);

// Add more to this buffer
buffer.put((byte)10);

IoBuffer buffer = IoBuffer.allocate(16);
buffer.setAutoShrink(true);
buffer.put((byte)1);
System.out.println("Initial Buffer capacity = "+buffer.capacity());
buffer.shrink();
System.out.println("Initial Buffer capacity after shrink = "+buffer.capacity());

buffer.capacity(32);
System.out.println("Buffer capacity after incrementing capacity to 32 = "+buffer.capacity());
buffer.shrink();
System.out.println("Buffer capacity after shrink= "+buffer.capacity());