Repository: activemq-artemis Updated Branches: refs/heads/master f149e76b3 -> 0d6e6a35f
ARTEMIS-368 - [Artemis Testsuite] TemporaryQueueTest#testBlockingWithTemporaryQueue fails Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3663f4c0 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3663f4c0 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3663f4c0 Branch: refs/heads/master Commit: 3663f4c01e69f315ea806530b78a791789d6a8ee Parents: f149e76 Author: Erich Duda <[email protected]> Authored: Fri Jan 29 09:57:49 2016 +0100 Committer: Erich Duda <[email protected]> Committed: Fri Jan 29 09:57:49 2016 +0100 ---------------------------------------------------------------------- .../tests/integration/client/TemporaryQueueTest.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3663f4c0/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TemporaryQueueTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TemporaryQueueTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TemporaryQueueTest.java index 2c47632..26a50d6 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TemporaryQueueTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TemporaryQueueTest.java @@ -570,7 +570,16 @@ public class TemporaryQueueTest extends SingleServerTestBase { Thread.sleep(100); } - while (t.isAlive() && errors.get() == 0 && !prod.getProducerCredits().isBlocked()) { + int blockedTime = 0; + + // https://issues.apache.org/jira/browse/ARTEMIS-368 + while (t.isAlive() && errors.get() == 0 && (!prod.getProducerCredits().isBlocked() || blockedTime < 60)) { + if (prod.getProducerCredits().isBlocked()) { + blockedTime++; + } + else { + blockedTime = 0; + } Thread.sleep(100); }
