ARTEMIS-333 Redistribution + groups tests failing

jbertram · Jan 6, 2016 · 6e70272 · 6e70272
1 parent 2e8ce98
commit 6e70272
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...a/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusterTestBase.java b/...a/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusterTestBase.java
@@ -512,7 +512,7 @@ protected void createQueue(final int node,
          throw new IllegalArgumentException("No sf at " + node);
       }
 
-      ClientSession session = addClientSession(sf.createSession(user, password, false, true, true, false, 0));
+      ClientSession session = addClientSession(sf.createSession(user, password, false, true, true, ActiveMQClient.DEFAULT_PRE_ACKNOWLEDGE, ActiveMQClient.DEFAULT_ACK_BATCH_SIZE));
 
       String filterString = null;
 
@@ -574,7 +574,7 @@ protected void addConsumer(final int consumerID,
             throw new IllegalArgumentException("No sf at " + node);
          }
 
-         ClientSession session = addClientSession(sf.createSession(user, password, false, false, autoCommitAcks, false, 0));
+         ClientSession session = addClientSession(sf.createSession(user, password, false, false, autoCommitAcks, ActiveMQClient.DEFAULT_PRE_ACKNOWLEDGE, ActiveMQClient.DEFAULT_ACK_BATCH_SIZE));
 
          String filterString = null;
 
@@ -1362,7 +1362,7 @@ protected void setupSessionFactory(final int node, final boolean netty, boolean
       addServerLocator(locators[node]);
       ClientSessionFactory sf = createSessionFactory(locators[node]);
 
-      ClientSession session = sf.createSession(user, password, false, true, true, false, 0);
+      ClientSession session = sf.createSession(user, password, false, true, true, ActiveMQClient.DEFAULT_PRE_ACKNOWLEDGE, ActiveMQClient.DEFAULT_ACK_BATCH_SIZE);
       session.close();
       sfs[node] = sf;
    }