Repository: activemq-artemis Updated Branches: refs/heads/master 2e8ce9889 -> d4dd07023
ARTEMIS-333 Redistribution + groups tests failing Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6e702724 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6e702724 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6e702724 Branch: refs/heads/master Commit: 6e702724b973124b78d1b2f020ac231b1d5812f6 Parents: 2e8ce98 Author: jbertram <jbert...@apache.org> Authored: Wed Jan 6 16:11:18 2016 -0600 Committer: jbertram <jbert...@apache.org> Committed: Wed Jan 6 16:15:19 2016 -0600 ---------------------------------------------------------------------- .../integration/cluster/distribution/ClusterTestBase.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6e702724/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusterTestBase.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusterTestBase.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusterTestBase.java index 7c3be5e..ec17435 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusterTestBase.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusterTestBase.java @@ -512,7 +512,7 @@ public abstract class ClusterTestBase extends ActiveMQTestBase { 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 @@ public abstract class ClusterTestBase extends ActiveMQTestBase { 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 @@ public abstract class ClusterTestBase extends ActiveMQTestBase { 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; }
