ExecutionHandler added to pipeline to improve client performance.

Author: menacher

jetclient/src/main/java/org/menacheri/jetclient/handlers/netty/ExecutionHandlerSingleton.java

@@ -0,0 +1,23 @@
+package org.menacheri.jetclient.handlers.netty;
+
+import org.jboss.netty.handler.execution.ExecutionHandler;
+import org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor;
+
+/**
+ * Creates an ExecutionHandler instance as a singleton.
+ * @author Abraham Menacherry
+ *
+ */
+public class ExecutionHandlerSingleton
+{
+	private static ExecutionHandler EXECUTION_HANDLER;
+
+	public synchronized static ExecutionHandler getExecutionHandler()
+	{
+		if(null == EXECUTION_HANDLER){
+			EXECUTION_HANDLER = new ExecutionHandler( new OrderedMemoryAwareThreadPoolExecutor(16, 1048576, 1048576));
+		}
+		return EXECUTION_HANDLER;
+	}
+	
+}

jetclient/src/main/java/org/menacheri/jetclient/handlers/netty/TCPPipelineFactory.java

@@ -5,6 +5,7 @@
 import org.jboss.netty.channel.Channels;
 import org.jboss.netty.handler.codec.frame.LengthFieldBasedFrameDecoder;
 import org.jboss.netty.handler.codec.frame.LengthFieldPrepender;
+import org.jboss.netty.handler.execution.ExecutionHandler;
 import org.menacheri.jetclient.app.ISession;
 import org.menacheri.jetclient.communication.IMessageBuffer;
 import org.menacheri.jetclient.event.IEvent;
@@ -38,20 +39,29 @@ public class TCPPipelineFactory implements ChannelPipelineFactory
 	 * {@link IEvent} instance to the next decoder/handler in the chain.
 	 */
 	private static final MessageBufferEventEncoder EVENT_ENCODER = new MessageBufferEventEncoder();
+	private final ExecutionHandler executionHandler;
 	/**
 	 * Used to transmit the message to {@link ISession}.
 	 */
 	private final DefaultToClientHandler defaultToClientHandler;
 
 	public TCPPipelineFactory(ISession session)
 	{
-		this(new DefaultToClientHandler(session));
+		this(new DefaultToClientHandler(session),null);
 	}
 
 	public TCPPipelineFactory(
-			final DefaultToClientHandler defaultToClientHandler)
+			final DefaultToClientHandler defaultToClientHandler, final ExecutionHandler executionHandler)
 	{
 		this.defaultToClientHandler = defaultToClientHandler;
+		if(null == executionHandler)
+		{
+			this.executionHandler = ExecutionHandlerSingleton.getExecutionHandler();
+		}
+		else
+		{
+			this.executionHandler = executionHandler;
+		}
 	}
 
 	@Override
@@ -60,6 +70,7 @@ public ChannelPipeline getPipeline() throws Exception
 		ChannelPipeline pipeline = Channels.pipeline();
 		pipeline.addLast("lengthDecoder", new LengthFieldBasedFrameDecoder(
 				Integer.MAX_VALUE, 0, 2, 0, 2));
+		pipeline.addLast("executionHandler", executionHandler);
 		pipeline.addLast("eventDecoder", EVENT_DECODER);
 		pipeline.addLast(DefaultToClientHandler.getName(),
 				defaultToClientHandler);

jetclient/src/main/java/org/menacheri/jetclient/handlers/netty/UDPPipelineFactory.java

@@ -30,6 +30,7 @@ public class UDPPipelineFactory implements ChannelPipelineFactory
 	static ChannelPipeline init()
 	{
 		ChannelPipeline pipeline = Channels.pipeline();
+		pipeline.addLast("executionHandler", ExecutionHandlerSingleton.getExecutionHandler());
 		pipeline.addLast("eventDecoder", EVENT_DECODER);
 		pipeline.addLast("eventEncoder", EVENT_ENCODER);
 		pipeline.addLast("UDPUpstreamHandler",UDP_UPSTREAM_HANDLER);