You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/08/23 14:49:44 UTC
activemq-artemis git commit: NO-JIRA fixing intermittent test failure
Repository: activemq-artemis
Updated Branches:
refs/heads/master a2602cb52 -> a85e75daa
NO-JIRA fixing intermittent test failure
There's no semantic change here, just a test fix
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a85e75da
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a85e75da
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a85e75da
Branch: refs/heads/master
Commit: a85e75daa16e4b62948704d44e8b6cbdc860871d
Parents: a2602cb
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Aug 23 10:48:46 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Aug 23 10:49:35 2017 -0400
----------------------------------------------------------------------
.../cluster/distribution/MessageRedistributionTest.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a85e75da/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java
index 0b0fa00..69c03cc 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/MessageRedistributionTest.java
@@ -259,6 +259,14 @@ public class MessageRedistributionTest extends ClusterTestBase {
ClientProducer producer0 = sess0.createProducer("queues.testaddress");
+ waitForBindings(0, "queues.testaddress", 1, 1, true);
+ waitForBindings(1, "queues.testaddress", 1, 1, true);
+ waitForBindings(2, "queues.testaddress", 1, 1, true);
+
+ waitForBindings(0, "queues.testaddress", 2, 2, false);
+ waitForBindings(1, "queues.testaddress", 2, 2, false);
+ waitForBindings(2, "queues.testaddress", 2, 2, false);
+
final int NUMBER_OF_MESSAGES = 1000;
for (int i = 0; i < 1000; i++) {