activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: ARTEMIS-333 Redistribution + groups tests failing
Date Thu, 07 Jan 2016 00:42:32 GMT
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 <jbertram@apache.org>
Authored: Wed Jan 6 16:11:18 2016 -0600
Committer: jbertram <jbertram@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;
    }


Mime
View raw message