Author: clebert.suconic(a)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");