Author: clebert.suconic(a)jboss.com Date: 2011-03-27 21:25:31 -0400 (Sun, 27 Mar 2011) New Revision: 10386 Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java Log: fixing test Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java =================================================================== --- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java 2011-03-28 01:20:38 UTC (rev 10385) +++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java 2011-03-28 01:25:31 UTC (rev 10386) @@ -55,12 +55,12 @@ protected void setUp() throws Exception { super.setUp(); - setupServer(JournalType.ASYNCIO); + setupServer(JournalType.NIO); } public void testProduceAndConsume() throws Throwable { - int numberOfConsumers = 60; + int numberOfConsumers = 5; // this test assumes numberOfConsumers == numberOfProducers int numberOfProducers = numberOfConsumers; int produceMessage = 10000; @@ -120,7 +120,7 @@ server.stop(); - setupServer(JournalType.ASYNCIO); + setupServer(JournalType.NIO); ClientSession sess = sf.createSession(true, true);