[hornetq-commits] JBoss hornetq SVN: r8252 - trunk/tests/src/org/hornetq/tests/integration/divert.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-11-09 04:47:36 -0500 (Mon, 09 Nov 2009)
New Revision: 8252

Modified:
   trunk/tests/src/org/hornetq/tests/integration/divert/DivertTest.java
Log:
increased receive timeout

* test failed because a long Full GC while calling consumer.receive(200)


Modified: trunk/tests/src/org/hornetq/tests/integration/divert/DivertTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/divert/DivertTest.java	2009-11-09 09:46:10 UTC (rev 8251)
+++ trunk/tests/src/org/hornetq/tests/integration/divert/DivertTest.java	2009-11-09 09:47:36 UTC (rev 8252)
@@ -44,6 +44,8 @@
 {
    private static final Logger log = Logger.getLogger(DivertTest.class);
 
+   private static final int TIMEOUT = 500;
+   
    public void testSingleNonExclusiveDivert() throws Exception
    {
       Configuration conf = createDefaultConfig();
@@ -107,7 +109,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -116,11 +118,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receive(500));
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer2.receive(200);
+         ClientMessage message = consumer2.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -129,7 +131,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receive(TIMEOUT));
 
       session.close();
 
@@ -213,7 +215,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -222,11 +224,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer2.receive(200);
+         ClientMessage message = consumer2.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -235,11 +237,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer3.receive(200);
+         ClientMessage message = consumer3.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -248,11 +250,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer4.receive(200);
+         ClientMessage message = consumer4.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -261,7 +263,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       session.close();
 
@@ -327,7 +329,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -336,7 +338,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
       session.close();
 
@@ -418,7 +420,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -427,13 +429,13 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       session.close();
 
@@ -537,7 +539,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -546,11 +548,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer2.receive(200);
+         ClientMessage message = consumer2.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -559,11 +561,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer3.receive(200);
+         ClientMessage message = consumer3.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -572,11 +574,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer4.receive(200);
+         ClientMessage message = consumer4.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -585,7 +587,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       session.close();
 
@@ -689,7 +691,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -698,11 +700,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer2.receive(200);
+         ClientMessage message = consumer2.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -711,11 +713,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer3.receive(200);
+         ClientMessage message = consumer3.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -724,7 +726,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
       assertNull(consumer4.receive(200));
 
@@ -830,7 +832,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -839,11 +841,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer2.receive(200);
+         ClientMessage message = consumer2.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -852,11 +854,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       session.close();
 
@@ -974,11 +976,11 @@
       // message.acknowledge();
       // }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer2.receive(200);
+         ClientMessage message = consumer2.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -987,11 +989,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer3.receive(200);
+         ClientMessage message = consumer3.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1000,11 +1002,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer4.receive(200);
+         ClientMessage message = consumer4.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1013,7 +1015,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
@@ -1028,7 +1030,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1037,13 +1039,13 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       session.close();
 
@@ -1147,7 +1149,7 @@
 
       for (int i = 0; i < numMessages;)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1162,7 +1164,7 @@
             break;
          }
 
-         message = consumer2.receive(200);
+         message = consumer2.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1177,7 +1179,7 @@
             break;
          }
 
-         message = consumer3.receive(200);
+         message = consumer3.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1188,13 +1190,13 @@
          i++;
       }
 
-      assertNull(consumer1.receive(200));
-      assertNull(consumer2.receive(200));
-      assertNull(consumer3.receive(200));
+      assertNull(consumer1.receiveImmediate());
+      assertNull(consumer2.receiveImmediate());
+      assertNull(consumer3.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer4.receive(200);
+         ClientMessage message = consumer4.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1203,7 +1205,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       session.close();
 
@@ -1309,7 +1311,7 @@
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer1.receive(200);
+         ClientMessage message = consumer1.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1318,13 +1320,13 @@
          message.acknowledge();
       }
 
-      assertNull(consumer1.receive(200));
+      assertNull(consumer1.receiveImmediate());
 
-      assertNull(consumer2.receive(200));
+      assertNull(consumer2.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer3.receive(200);
+         ClientMessage message = consumer3.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1333,11 +1335,11 @@
          message.acknowledge();
       }
 
-      assertNull(consumer3.receive(200));
+      assertNull(consumer3.receiveImmediate());
 
       for (int i = 0; i < numMessages; i++)
       {
-         ClientMessage message = consumer4.receive(200);
+         ClientMessage message = consumer4.receive(TIMEOUT);
 
          assertNotNull(message);
 
@@ -1346,7 +1348,7 @@
          message.acknowledge();
       }
 
-      assertNull(consumer4.receive(200));
+      assertNull(consumer4.receiveImmediate());
 
       session.close();