[jboss-cvs] JBoss Messaging SVN: r4015 - trunk/tests/src/org/jboss/messaging/core/remoting/impl/mina/integration/test.

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

Author: jmesnil
Date: 2008-04-07 10:23:57 -0400 (Mon, 07 Apr 2008)
New Revision: 4015

Modified:
   trunk/tests/src/org/jboss/messaging/core/remoting/impl/mina/integration/test/MinaHandlerOrderingTest.java
Log:
* tweak test (less messages sent to the 2nd handler but slowed it down)

Modified: trunk/tests/src/org/jboss/messaging/core/remoting/impl/mina/integration/test/MinaHandlerOrderingTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/core/remoting/impl/mina/integration/test/MinaHandlerOrderingTest.java	2008-04-07 12:28:48 UTC (rev 4014)
+++ trunk/tests/src/org/jboss/messaging/core/remoting/impl/mina/integration/test/MinaHandlerOrderingTest.java	2008-04-07 14:23:57 UTC (rev 4015)
@@ -16,8 +16,10 @@
 import junit.framework.TestCase;
 
 import org.jboss.messaging.core.remoting.PacketDispatcher;
+import org.jboss.messaging.core.remoting.PacketSender;
 import org.jboss.messaging.core.remoting.impl.PacketDispatcherImpl;
 import org.jboss.messaging.core.remoting.impl.mina.MinaHandler;
+import org.jboss.messaging.core.remoting.impl.wireformat.Packet;
 import org.jboss.messaging.core.remoting.impl.wireformat.TextPacket;
 import org.jboss.messaging.core.remoting.test.unit.TestPacketHandler;
 
@@ -39,7 +41,7 @@
 
    // Constants -----------------------------------------------------
 
-   private static final int MANY_MESSAGES = 10000;
+   private static final int MANY_MESSAGES = 50;
    
    // Attributes ----------------------------------------------------
 
@@ -81,7 +83,7 @@
       int size = handler_2.getPackets().size();
       assertTrue("handler_2 should not have received all its message (size:" + size + ")", size < MANY_MESSAGES);
 
-      assertTrue(handler_2.await(5, SECONDS));
+      assertTrue(handler_2.await(2, SECONDS));
       List<TextPacket> packetsReceivedByHandler_2 = handler_2.getPackets();
       assertEquals(MANY_MESSAGES, packetsReceivedByHandler_2.size());      
       // we check that handler_2 receives all its messages in order:
@@ -103,7 +105,21 @@
 
       handler_1 = new TestPacketHandler();
       clientDispatcher.register(handler_1);
-      handler_2 = new TestPacketHandler();
+      handler_2 = new TestPacketHandler() {
+        @Override
+         public void handle(Packet packet, PacketSender sender)
+         {
+           // slow down the 2nd handler
+           try
+           {
+              Thread.sleep(10);
+           } catch (InterruptedException e)
+           {
+              e.printStackTrace();
+           }           
+           super.handle(packet, sender);
+         } 
+      };
       clientDispatcher.register(handler_2);
    }