[jboss-cvs] JBoss Messaging SVN: r5964 - trunk/src/main/org/jboss/messaging/integration/transports/netty.

[jboss-cvs-commits at lists.jboss.org]

Author: ataylor
Date: 2009-03-02 13:40:06 -0500 (Mon, 02 Mar 2009)
New Revision: 5964

Modified:
   trunk/src/main/org/jboss/messaging/integration/transports/netty/NettyAcceptor.java
Log:
removed local channel binding

Modified: trunk/src/main/org/jboss/messaging/integration/transports/netty/NettyAcceptor.java
===================================================================
--- trunk/src/main/org/jboss/messaging/integration/transports/netty/NettyAcceptor.java	2009-03-02 17:40:14 UTC (rev 5963)
+++ trunk/src/main/org/jboss/messaging/integration/transports/netty/NettyAcceptor.java	2009-03-02 18:40:06 UTC (rev 5964)
@@ -123,10 +123,6 @@
 
    private ConcurrentMap<Object, Connection> connections = new ConcurrentHashMap<Object, Connection>();
 
-   private Channel localChannel;
-
-   private int inVmServerId;
-
    public NettyAcceptor(final Map<String, Object> configuration,
                         final BufferHandler handler,
                         final ConnectionLifeCycleListener listener)
@@ -202,9 +198,6 @@
       this.tcpReceiveBufferSize = ConfigurationHelper.getIntProperty(TransportConstants.TCP_RECEIVEBUFFER_SIZE_PROPNAME,
                                                                      TransportConstants.DEFAULT_TCP_RECEIVEBUFFER_SIZE,
                                                                      configuration);
-
-
-      inVmServerId = ConfigurationHelper.getIntProperty(org.jboss.messaging.core.remoting.impl.invm.TransportConstants.SERVER_ID_PROP_NAME, 0, configuration);
    }
 
    public synchronized void start() throws Exception
@@ -292,11 +285,6 @@
          Channel serverChannel = bootstrap.bind(new InetSocketAddress(h, port));
          serverChannelGroup.add(serverChannel);
       }
-      LocalServerChannelFactory localServerChannelFactory = new DefaultLocalServerChannelFactory();
-      ServerBootstrap localBoot = new ServerBootstrap(localServerChannelFactory);
-      localBoot.setPipelineFactory(factory);
-      LocalAddress localAddress = new LocalAddress("org.jboss.jbm." + inVmServerId);
-      localChannel = localBoot.bind(localAddress);
    }
 
    public synchronized void stop()
@@ -313,7 +301,6 @@
 
          httpKeepAliveTimer.cancel();
       }
-      localChannel.unbind();
       serverChannelGroup.close().awaitUninterruptibly();
       bossExecutor.shutdown();
       workerExecutor.shutdown();