[hornetq-commits] JBoss hornetq SVN: r11918 - 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-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)
       {