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