NO-JIRA fixing tests
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6bdff442 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6bdff442 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6bdff442 Branch: refs/heads/master Commit: 6bdff442ab72474623c7bc3fe0eafea8b8dbb5f2 Parents: 638ff75 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Fri Nov 2 15:41:52 2018 -0400 Committer: Michael Andre Pearce <michael.andre.pea...@me.com> Committed: Thu Nov 8 23:45:32 2018 +0000 ---------------------------------------------------------------------- .../artemis/tests/integration/management/QueueControlTest.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6bdff442/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java index d64eba6..71780e9 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java @@ -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);
