Problem with sending/receiving Http POST request with Netty (solved)

NettyTest.java

import static org.jboss.netty.handler.codec.http.HttpHeaders.Names.CONTENT_TYPE;
import static org.jboss.netty.handler.codec.http.HttpResponseStatus.OK;
import static org.jboss.netty.handler.codec.http.HttpVersion.HTTP_1_1;

import java.net.InetSocketAddress;
import java.nio.charset.Charset;
import java.util.concurrent.Executors;

import junit.framework.Assert;

import org.jboss.netty.bootstrap.ClientBootstrap;
import org.jboss.netty.bootstrap.ServerBootstrap;
import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.buffer.ChannelBuffers;
import org.jboss.netty.channel.Channel;
import org.jboss.netty.channel.ChannelFutureListener;
import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;
import org.jboss.netty.channel.Channels;
import org.jboss.netty.channel.ExceptionEvent;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.channel.SimpleChannelUpstreamHandler;
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
import org.jboss.netty.handler.codec.http.DefaultHttpRequest;
import org.jboss.netty.handler.codec.http.DefaultHttpResponse;
import org.jboss.netty.handler.codec.http.HttpChunkAggregator;
import org.jboss.netty.handler.codec.http.HttpClientCodec;
import org.jboss.netty.handler.codec.http.HttpMethod;
import org.jboss.netty.handler.codec.http.HttpRequest;
import org.jboss.netty.handler.codec.http.HttpRequestDecoder;
import org.jboss.netty.handler.codec.http.HttpResponse;
import org.jboss.netty.handler.codec.http.HttpResponseEncoder;
import org.jboss.netty.handler.codec.http.HttpVersion;
import org.jboss.netty.util.CharsetUtil;
import org.junit.Test;

public class NettyTest {
	private static StringBuffer buf = new StringBuffer();

	@Test
	public void test() {
		ServerBootstrap server = new ServerBootstrap(
				new NioServerSocketChannelFactory(
						Executors.newCachedThreadPool(),
						Executors.newCachedThreadPool()));

		server.setPipelineFactory(new ServerPipelineFactory());

		server.bind(new InetSocketAddress(10000));

		ClientBootstrap client = new ClientBootstrap(
				new NioClientSocketChannelFactory(
						Executors.newCachedThreadPool(),
						Executors.newCachedThreadPool()));

		client.setPipelineFactory(new ClientPipelineFactory());

		//Connect to server, wait till connection is established, get channel to write to
		Channel channel = client.connect(new InetSocketAddress("127.0.0.1", 10000)).awaitUninterruptibly().getChannel();
		{
			//Writing request to channel and wait till channel is closed from server
			HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, "test");
			ChannelBuffer buffer = ChannelBuffers.copiedBuffer("ping", Charset.defaultCharset());
			request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, buffer.readableBytes());
			request.setContent(buffer);

			channel.write(request).awaitUninterruptibly().getChannel().getCloseFuture().awaitUninterruptibly();
		}
		client.releaseExternalResources();
		server.releaseExternalResources();
		String expected = "pingpong";
		Assert.assertEquals(expected, buf.toString());
	}

	private static class TestRequestHandler extends SimpleChannelUpstreamHandler {

		@Override
		public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {

			//Processing request, here is the problem. The string from the content is empty.
			buf.append(((HttpRequest) e.getMessage()).getContent().toString(CharsetUtil.UTF_8));

			//Writing response, wait till it is completely written and close channel after that
			HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);
			response.setContent(ChannelBuffers.copiedBuffer("pong", CharsetUtil.UTF_8));
			response.setHeader(CONTENT_TYPE, "text/plain; charset=UTF-8");
			e.getChannel().write(response).addListener(ChannelFutureListener.CLOSE);

		}

		@Override
		public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {
			super.exceptionCaught(ctx, e);
		}
	}

	private static class ServerPipelineFactory implements ChannelPipelineFactory {

		@Override
		public ChannelPipeline getPipeline() throws Exception {
			ChannelPipeline pipeline = Channels.pipeline();

			pipeline.addLast("decoder", new HttpRequestDecoder());
			pipeline.addLast("aggregator", new HttpChunkAggregator(1048576));
			pipeline.addLast("encoder", new HttpResponseEncoder());
			pipeline.addLast("handler", new TestRequestHandler());

			return pipeline;
		}

	}

	private static class ClientPipelineFactory implements ChannelPipelineFactory {

		@Override
		public ChannelPipeline getPipeline() throws Exception {
			ChannelPipeline pipeline = Channels.pipeline();

			pipeline.addLast("codec", new HttpClientCodec());

			pipeline.addLast("aggregator", new HttpChunkAggregator(1048576));

			pipeline.addLast("handler", new TestResponseHandler());
			return pipeline;
		}
	}

	private static class TestResponseHandler extends SimpleChannelUpstreamHandler {
		@Override
		public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
			HttpResponse responce = (HttpResponse) e.getMessage();
			buf.append(responce.getContent().toString(CharsetUtil.UTF_8));
			super.messageReceived(ctx, e);
		}
	}
}

Hi isopov,I'm new to netty so how we can execute this code without main method.