[jboss-cvs] JBoss Messaging SVN: r5163 - in branches/amqp_integration: src/main/org/jboss/messaging/core/remoting/impl/invm and 4 other directories.

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

Author: jmesnil
Date: 2008-10-21 10:13:48 -0400 (Tue, 21 Oct 2008)
New Revision: 5163

Modified:
   branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/RemotingServiceImpl.java
   branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/invm/InVMAcceptor.java
   branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaAcceptor.java
   branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java
   branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/spi/Acceptor.java
   branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory1.java
   branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory2.java
   branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory3.java
Log:
removed useless method setMessagingServer(MessagingServer) from Acceptor interface and its implementations

Modified: branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/RemotingServiceImpl.java
===================================================================
--- branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/RemotingServiceImpl.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/RemotingServiceImpl.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -215,10 +215,6 @@
    public void setMessagingServer(final MessagingServer server)
    {
       this.server = server;
-      for (Acceptor acceptor : acceptors)
-      {
-         acceptor.setMessagingServer(server);
-      }
    }
 
    public void setBackup(final boolean backup)

Modified: branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/invm/InVMAcceptor.java
===================================================================
--- branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/invm/InVMAcceptor.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/invm/InVMAcceptor.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -30,7 +30,6 @@
 import org.jboss.messaging.core.remoting.spi.BufferHandler;
 import org.jboss.messaging.core.remoting.spi.Connection;
 import org.jboss.messaging.core.remoting.spi.ConnectionLifeCycleListener;
-import org.jboss.messaging.core.server.MessagingServer;
 import org.jboss.messaging.util.ConfigurationHelper;
 
 /**
@@ -94,10 +93,6 @@
       started = true;
    }
    
-   public void setMessagingServer(MessagingServer server)
-   {
-   }
-
    public BufferHandler getHandler()
    {
       if (!started)

Modified: branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaAcceptor.java
===================================================================
--- branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaAcceptor.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/mina/MinaAcceptor.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -62,7 +62,6 @@
 import org.jboss.messaging.core.remoting.spi.BufferHandler;
 import org.jboss.messaging.core.remoting.spi.Connection;
 import org.jboss.messaging.core.remoting.spi.ConnectionLifeCycleListener;
-import org.jboss.messaging.core.server.MessagingServer;
 import org.jboss.messaging.util.ConfigurationHelper;
 
 
@@ -208,10 +207,6 @@
       acceptor = null;
    }
 
-   public void setMessagingServer(MessagingServer server)
-   {
-   }
-
    public DefaultIoFilterChainBuilder getFilterChain()
    {
       return acceptor.getFilterChain();

Modified: branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java
===================================================================
--- branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/impl/netty/NettyAcceptor.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -60,7 +60,6 @@
 import org.jboss.messaging.core.remoting.spi.BufferHandler;
 import org.jboss.messaging.core.remoting.spi.Connection;
 import org.jboss.messaging.core.remoting.spi.ConnectionLifeCycleListener;
-import org.jboss.messaging.core.server.MessagingServer;
 import org.jboss.messaging.util.ConfigurationHelper;
 import org.jboss.messaging.util.JBMThreadFactory;
 import org.jboss.netty.bootstrap.ServerBootstrap;
@@ -269,10 +268,6 @@
       channelFactory = null;
    }
 
-   public void setMessagingServer(MessagingServer server)
-   {
-   }
-
    // Inner classes -----------------------------------------------------------------------------
 
    @ChannelPipelineCoverage("one")

Modified: branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/spi/Acceptor.java
===================================================================
--- branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/spi/Acceptor.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/src/main/org/jboss/messaging/core/remoting/spi/Acceptor.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -22,7 +22,6 @@
 
 package org.jboss.messaging.core.remoting.spi;
 
-import org.jboss.messaging.core.server.MessagingServer;
 
 /**
  * An Acceptor is used tby the Remoting Service to allow clients to connect. It should take care of dispatchin client requests
@@ -36,6 +35,4 @@
    void start() throws Exception;
 
    void stop();
-
-   void setMessagingServer(MessagingServer server);
 }

Modified: branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory1.java
===================================================================
--- branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory1.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory1.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -55,12 +55,6 @@
       public void stop()
       {  
       }
-      
-      public void setMessagingServer(MessagingServer server)
-      {
-      }
-
-
    }
    
 }

Modified: branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory2.java
===================================================================
--- branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory2.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory2.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -55,12 +55,7 @@
       public void stop()
       {  
       }
-      
-      public void setMessagingServer(MessagingServer server)
-      {
-      }
-
-      
+            
    }
    
 }

Modified: branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory3.java
===================================================================
--- branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory3.java	2008-10-21 10:39:09 UTC (rev 5162)
+++ branches/amqp_integration/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/AcceptorFactory3.java	2008-10-21 14:13:48 UTC (rev 5163)
@@ -55,12 +55,7 @@
       public void stop()
       {  
       }
-      
-      public void setMessagingServer(MessagingServer server)
-      {
-      }
 
-
    }
    
 }