[hornetq-commits] JBoss hornetq SVN: r10096 - trunk/tests/src/org/hornetq/tests/stress/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-01-01 15:59:31 -0500 (Sat, 01 Jan 2011)
New Revision: 10096

Modified:
   trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java
Log:
fixing test

Modified: trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java	2011-01-01 20:54:50 UTC (rev 10095)
+++ trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java	2011-01-01 20:59:31 UTC (rev 10096)
@@ -51,8 +51,6 @@
 
    private ClientSessionFactory sf;
 
-   private ServerLocator locator;
-
    @Override
    protected void setUp() throws Exception
    {
@@ -151,8 +149,6 @@
    @Override
    protected void tearDown() throws Exception
    {
-      locator.close();
-
       try
       {
          if (server != null && server.isStarted())
@@ -188,13 +184,13 @@
 
       ServerLocator locator = createNettyNonHALocator();
 
-      sf = locator.createSessionFactory();
+      locator.setBlockOnDurableSend(false);
 
-      sf.getServerLocator().setBlockOnDurableSend(false);
+      locator.setBlockOnNonDurableSend(false);
 
-      sf.getServerLocator().setBlockOnNonDurableSend(false);
+      locator.setBlockOnAcknowledge(false);
 
-      sf.getServerLocator().setBlockOnAcknowledge(false);
+      sf = locator.createSessionFactory();
 
       ClientSession sess = sf.createSession();