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-1250 ClusteredMessageCounterTest.testNonDurableMessageAddedWithPaging fails
Date Fri, 23 Jun 2017 12:56:44 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master e709fc366 -> d6191e31e


ARTEMIS-1250 ClusteredMessageCounterTest.testNonDurableMessageAddedWithPaging fails

Before sending of messages to server 0 begins, the test
should wait until consumer is registered at RemoteQueueBindingImpl
on server 0. Otherwise some messages may not be rebalanced
to server 1.


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

Branch: refs/heads/master
Commit: c5a25d33226aa261204e0a2779b0e87bfdcf1395
Parents: e709fc3
Author: Erich Duda <eduda@redhat.com>
Authored: Fri Jun 23 13:39:25 2017 +0200
Committer: Erich Duda <eduda@redhat.com>
Committed: Fri Jun 23 13:39:25 2017 +0200

----------------------------------------------------------------------
 .../cluster/distribution/ClusteredMessageCounterTest.java        | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/c5a25d33/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusteredMessageCounterTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusteredMessageCounterTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusteredMessageCounterTest.java
index f21088e..d59b03e 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusteredMessageCounterTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusteredMessageCounterTest.java
@@ -127,10 +127,12 @@ public class ClusteredMessageCounterTest extends ClusterTestBase {
 
          addConsumer(1, 1, "queue0", null);
 
+         waitForBindings(0, "queues", 1, 1, false);
+
          System.out.println("sending.....");
          send(0, "queues", numMsg, durable, null);
 
-         verifyReceiveAllOnSingleConsumer(true, numMsg, 1);
+         verifyReceiveAllOnSingleConsumer(true, 0, numMsg, 1);
 
          QueueControl control = (QueueControl) servers[1].getManagementService().getResource(ResourceNames.QUEUE
+ "queue0");
 


Mime
View raw message