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

This closes #2413

This commit is contained in:
Michael Andre Pearce 2018-11-08 23:45:32 +00:00
parent 638ff75f4b 6bdff442ab
commit b08541997b
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java
View File

@ -1790,6 +1790,7 @@ public class QueueControlTest extends ManagementTestBase {
producer.send(matchingMessage);
producer.send(unmatchingMessage);
producer.send(matchingMessage);
session.commit();
QueueControl queueControl = createManagementControl(address, queue);
String result = queueControl.countDeliveringMessages(null, null);
@ -1866,6 +1867,7 @@ public class QueueControlTest extends ManagementTestBase {
producer.send(message1);
producer.send(message2);
producer.send(message1);
session.commit();
QueueControl queueControl = createManagementControl(address, queue);
String result = queueControl.countDeliveringMessages(key + " =" + valueGroup1, key);