[jboss-cvs] JBoss Messaging SVN: r7638 - trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/netty.

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

Author: jmesnil
Date: 2009-07-29 06:37:54 -0400 (Wed, 29 Jul 2009)
New Revision: 7638

Modified:
   trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/netty/NettyAcceptorTest.java
Log:
* added testPauseResume

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/netty/NettyAcceptorTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/netty/NettyAcceptorTest.java	2009-07-29 10:17:35 UTC (rev 7637)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/netty/NettyAcceptorTest.java	2009-07-29 10:37:54 UTC (rev 7638)
@@ -104,17 +104,50 @@
       acceptor.stop();
       assertFalse(acceptor.isStarted());
       checkFreePort(TransportConstants.DEFAULT_PORT);
+   }
+   
+   public void testPauseResume() throws Exception
+   {
+      BufferHandler handler = new AbstractBufferHandler()
+      {
 
+         public void bufferReceived(Object connectionID, MessagingBuffer buffer)
+         {
+         }
+      };
+
+      Map<String, Object> params = new HashMap<String, Object>();
+      ConnectionLifeCycleListener listener = new ConnectionLifeCycleListener()
+      {
+
+         public void connectionException(Object connectionID, MessagingException me)
+         {
+         }
+
+         public void connectionDestroyed(Object connectionID)
+         {
+         }
+
+         public void connectionCreated(Connection connection)
+         {
+         }
+      };
+      NettyAcceptor acceptor = new NettyAcceptor(params, handler, listener, 
+                                                 Executors.newCachedThreadPool(), 
+                                                 Executors.newScheduledThreadPool(ConfigurationImpl.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE));
+
       acceptor.start();
       assertTrue(acceptor.isStarted());
+
       acceptor.pause();
-      acceptor.resume();
       acceptor.stop();
       assertFalse(acceptor.isStarted());
       checkFreePort(TransportConstants.DEFAULT_PORT);
 
       acceptor.start();
       assertTrue(acceptor.isStarted());
+      acceptor.pause();
+      acceptor.resume();
       acceptor.stop();
       assertFalse(acceptor.isStarted());
       checkFreePort(TransportConstants.DEFAULT_PORT);