Author: clebert.suconic(a)jboss.com
Date: 2011-12-20 20:27:21 -0500 (Tue, 20 Dec 2011)
New Revision: 11918
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java
Log:
https://issues.jboss.org/browse/JBPAPP-7706 - small change on test
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java
===================================================================
---
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java 2011-12-20
22:17:53 UTC (rev 11917)
+++
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/TestFlowControlOnIgnoreLargeMessageBodyTest.java 2011-12-21
01:27:21 UTC (rev 11918)
@@ -52,7 +52,7 @@
private static final String ATTR_MSG_COUNTER = "msgIdex";
- protected int receiveTimeout = 2000;
+ protected int receiveTimeout = 10000;
private volatile boolean error = false;
@@ -146,6 +146,7 @@
}
catch (Exception e)
{
+ error = true;
e.printStackTrace();
}
finally
@@ -256,6 +257,7 @@
{
if (invalidOrderCounter < 10)
{
+ error = true;
System.out.println("Invalid messages order! expected: "
+ counter +
", received " +
msg.getIntProperty(TestFlowControlOnIgnoreLargeMessageBodyTest.ATTR_MSG_COUNTER) +
@@ -366,7 +368,7 @@
{
if (consumer.getReceivedMessages() !=
TestFlowControlOnIgnoreLargeMessageBodyTest.TOTAL_MESSAGES_COUNT)
{
- errorMessage = "Producer did not send defined count of
messages";
+ errorMessage = "Consumer did not send defined count of
messages";
break;
}
}
@@ -381,6 +383,8 @@
{
System.out.println(" OK ");
}
+
+ assertFalse(error);
}
catch (Exception e)
{