activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: ARTEMIS-368 - [Artemis Testsuite] TemporaryQueueTest#testBlockingWithTemporaryQueue fails
Date Fri, 29 Jan 2016 14:30:23 GMT
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 <eduda@redhat.com>
Authored: Fri Jan 29 09:57:49 2016 +0100
Committer: Erich Duda <eduda@redhat.com>
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);
       }
 


Mime
View raw message