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/06/23 12:56:44 UTC
[1/2] activemq-artemis git commit: ARTEMIS-1250
ClusteredMessageCounterTest.testNonDurableMessageAddedWithPaging fails
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 <ed...@redhat.com>
Authored: Fri Jun 23 13:39:25 2017 +0200
Committer: Erich Duda <ed...@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");
[2/2] activemq-artemis git commit: This closes #1362
Posted by cl...@apache.org.
This closes #1362
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/d6191e31
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/d6191e31
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/d6191e31
Branch: refs/heads/master
Commit: d6191e31e243aecdae299da9f156f23eaa99a798
Parents: e709fc3 c5a25d3
Author: Clebert Suconic <cl...@apache.org>
Authored: Fri Jun 23 08:56:40 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Fri Jun 23 08:56:40 2017 -0400
----------------------------------------------------------------------
.../cluster/distribution/ClusteredMessageCounterTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------