[hornetq-commits] JBoss hornetq SVN: r11978 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client.
Author: clebert.suconic(a)jboss.com
Date: 2012-01-05 11:28:35 -0500 (Thu, 05 Jan 2012)
New Revision: 11978
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java
Log:
small fix on test - no code changes besides the test
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java
===================================================================
---
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java 2012-01-05
14:07:02 UTC (rev 11977)
+++
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java 2012-01-05
16:28:35 UTC (rev 11978)
@@ -303,7 +303,7 @@
consumers.add(consumer);
session1.start();
sessions.add(session1);
- consumer.receive(10);
+ assertNull(consumer.receive(10));
}
@@ -321,7 +321,7 @@
senderSession.start();
ClientConsumer consumer = consumers.get(2);
- ClientMessage received = consumer.receiveImmediate();
+ ClientMessage received = consumer.receive(5000);
assertNotNull(received);
for (ClientSession tmpSess : sessions)