activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject activemq-artemis git commit: ARTEMIS-1297 fixing intermittent failure
Date Tue, 29 Aug 2017 23:04:34 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 0610a2349 -> 9df2ffe24


ARTEMIS-1297 fixing intermittent failure


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9df2ffe2
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9df2ffe2
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9df2ffe2

Branch: refs/heads/master
Commit: 9df2ffe248af1ecf24aec740e2fce4148d2a1d4f
Parents: 0610a23
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Tue Aug 29 19:04:23 2017 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Tue Aug 29 19:04:23 2017 -0400

----------------------------------------------------------------------
 .../cluster/distribution/AMQPMessageLoadBalancingTest.java    | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9df2ffe2/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java
index ba4cdaf..53a430f 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/AMQPMessageLoadBalancingTest.java
@@ -67,6 +67,13 @@ public class AMQPMessageLoadBalancingTest extends ClusterTestBase {
       createQueue(0, "queues.0", "queues.0", null, true, null, null, RoutingType.ANYCAST);
       createQueue(1, "queues.0", "queues.0", null, true, null, null, RoutingType.ANYCAST);
 
+      waitForBindings(0, "queues.0", 1, 0, true);
+      waitForBindings(1, "queues.0", 1, 0, true);
+
+      waitForBindings(0, "queues.0", 1, 0, false);
+      waitForBindings(1, "queues.0", 1, 0, false);
+
+
       final int NUMBER_OF_MESSAGES = 100;
 
       // sending AMQP Messages.. they should be load balanced


Mime
View raw message