[hornetq-commits] JBoss hornetq SVN: r10757 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-05-31 18:23:29 -0400 (Tue, 31 May 2011)
New Revision: 10757

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java
Log:
just a test fix

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java	2011-05-31 21:51:56 UTC (rev 10756)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingTest.java	2011-05-31 22:23:29 UTC (rev 10757)
@@ -3787,7 +3787,7 @@
 
             try
             {
-               if (!message.waitOutputStreamCompletion(5000))
+               if (!message.waitOutputStreamCompletion(10000))
                {
                   log.info(threadDump("dump"));
                   fail("Couldn't finish large message receiving");
@@ -3795,6 +3795,7 @@
             }
             catch (Throwable e)
             {
+               log.info(threadDump("dump"));
                fail("Couldn't finish large message receiving for id=" + message.getStringProperty("id") + " with messageID=" + message.getMessageID());
             }
 
@@ -3804,6 +3805,13 @@
 
          cons.close();
          
+         cons = session.createConsumer("DLA");
+         
+         for (int i = 0 ; i < 2; i++)
+         {
+            assertNotNull(cons.receive(5000));
+         }
+         
          sf.close();
          
          session.close();
@@ -3846,6 +3854,8 @@
             assertTrue(message.waitOutputStreamCompletion(5000));
          }
          
+         assertNull(cons.receiveImmediate());
+         
          cons.close();
          
          cons = session.createConsumer("DLA");