[hornetq-commits] JBoss hornetq SVN: r11107 - branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/reattach.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-08-03 18:16:02 -0400 (Wed, 03 Aug 2011)
New Revision: 11107

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/reattach/OrderReattachTest.java
Log:
fixing test

Modified: branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/reattach/OrderReattachTest.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/reattach/OrderReattachTest.java	2011-08-03 21:18:53 UTC (rev 11106)
+++ branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/reattach/OrderReattachTest.java	2011-08-03 22:16:02 UTC (rev 11107)
@@ -41,15 +41,6 @@
  */
 public class OrderReattachTest extends ServiceTestBase
 {
-
-   // Disabled for now... under investigation (Clebert)
-   public static TestSuite suite()
-   {
-      TestSuite suite = new TestSuite();
-
-      return suite;
-   }
-
    // Constants -----------------------------------------------------
 
    final SimpleString ADDRESS = new SimpleString("address");
@@ -67,13 +58,7 @@
 
    public void testOrderOnSendInVM() throws Throwable
    {
-      for (int i = 0; i < 500; i++)
-      {
-         log.info("#" + getName() + " # " + i);
-         doTestOrderOnSend(false);
-         tearDown();
-         setUp();
-      }
+      doTestOrderOnSend(false);
    }
 
    public void doTestOrderOnSend(final boolean isNetty) throws Throwable
@@ -83,7 +68,7 @@
       server.start();
       ServerLocator locator = createFactory(isNetty);
       locator.setReconnectAttempts(-1);
-      locator.setConfirmationWindowSize(100 * 1024 * 1024);
+      locator.setConfirmationWindowSize(1024 * 1024);
       locator.setBlockOnNonDurableSend(false);
       locator.setBlockOnAcknowledge(false);
       ClientSessionFactory sf = locator.createSessionFactory();
@@ -192,7 +177,7 @@
 
       final int numMessages = 500;
 
-      final int numSessions = 100;
+      final int numSessions = 10;
 
       Set<ClientConsumer> consumers = new HashSet<ClientConsumer>();
       Set<ClientSession> sessions = new HashSet<ClientSession>();