From dcbaac71303e606662c8274d5b936fd8323a01b0 Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton.tananaev@gmail.com>
Date: Thu, 9 Jun 2011 08:50:44 +0000
Subject:

---
 .../sourceforge/opentracking/TrackerServer.java    | 29 ++--------------------
 1 file changed, 2 insertions(+), 27 deletions(-)

(limited to 'src/net/sourceforge/opentracking/TrackerServer.java')

diff --git a/src/net/sourceforge/opentracking/TrackerServer.java b/src/net/sourceforge/opentracking/TrackerServer.java
index 4b38920c7..dc9981e61 100644
--- a/src/net/sourceforge/opentracking/TrackerServer.java
+++ b/src/net/sourceforge/opentracking/TrackerServer.java
@@ -23,34 +23,12 @@ import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
 import org.jboss.netty.channel.group.ChannelGroup;
 import org.jboss.netty.channel.group.DefaultChannelGroup;
 import org.jboss.netty.channel.group.ChannelGroupFuture;
-import org.jboss.netty.channel.SimpleChannelHandler;
-import org.jboss.netty.channel.ChannelHandlerContext;
-import org.jboss.netty.channel.ChannelStateEvent;
-import org.jboss.netty.channel.ChannelPipelineCoverage;
 
 /**
  * Tracker server
  */
 public class TrackerServer extends ServerBootstrap {
 
-    /**
-     * Open channel handler
-     */
-    @ChannelPipelineCoverage("all")
-    protected class OpenChannelHandler extends SimpleChannelHandler {
-
-        TrackerServer server;
-
-        public OpenChannelHandler(TrackerServer newServer) {
-            server = newServer;
-        }
-
-        @Override
-        public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e) {
-            server.getChannelGroup().add(e.getChannel());
-        }
-    }
-
     /**
      * Initialization
      */
@@ -60,11 +38,8 @@ public class TrackerServer extends ServerBootstrap {
 
         // Create channel factory
         setFactory(new NioServerSocketChannelFactory(
-                Executors.newFixedThreadPool(threadPoolSize),
-                Executors.newFixedThreadPool(threadPoolSize)));
-
-        // Add open channel handler
-        getPipeline().addLast("openHandler", new OpenChannelHandler(this));
+                Executors.newCachedThreadPool(),
+                Executors.newCachedThreadPool()));
     }
 
     public TrackerServer(Integer port) {
-- 
cgit v1.2.3