Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-645 ClusteredGroupingTest fails 

In testGroupingSendTo3queuesNoConsumerOnLocalQueue the batch
of messages can be received also by the second consumer. It
depends on cluster decision.
This commit is contained in:
Erich Duda 2016-07-20 15:48:10 +02:00 committed by Andy Taylor
parent 771dab13bf
commit d0cb3b1d17
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ClusteredGroupingTest.java
View File

@ -1225,15 +1225,28 @@ public class ClusteredGroupingTest extends ClusterTestBase {
waitForBindings(1, "queues.testaddress", 2, 2, false);
waitForBindings(2, "queues.testaddress", 2, 1, false);
sendInRange(1, "queues.testaddress", 0, 1, false, Message.HDR_GROUP_ID, new SimpleString("id1"));
int consumer = 0;
if (consumers[0].consumer.receive(5000) != null) {
consumer = 0;
}
else if (consumers[2].consumer.receive(5000) != null) {
consumer = 2;
}
else {
fail("Message was not received.");
}
sendInRange(1, "queues.testaddress", 0, 10, false, Message.HDR_GROUP_ID, new SimpleString("id1"));
verifyReceiveAllInRange(0, 10, 0);
verifyReceiveAllInRange(0, 10, consumer);
sendInRange(2, "queues.testaddress", 10, 20, false, Message.HDR_GROUP_ID, new SimpleString("id1"));
verifyReceiveAllInRange(10, 20, 0);
verifyReceiveAllInRange(10, 20, consumer);
sendInRange(0, "queues.testaddress", 20, 30, false, Message.HDR_GROUP_ID, new SimpleString("id1"));
verifyReceiveAllInRange(20, 30, 0);
verifyReceiveAllInRange(20, 30, consumer);
}