activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject git commit: tidy up test completion, allowing consumers to exit gracefully from blocking receive
Date Fri, 21 Mar 2014 13:16:17 GMT
Repository: activemq
Updated Branches:
  refs/heads/trunk 9bf9e1c05 -> f594cdab1


tidy up test completion, allowing consumers to exit gracefully from blocking receive


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/f594cdab
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/f594cdab
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/f594cdab

Branch: refs/heads/trunk
Commit: f594cdab107ca4dfde92f39e670f1d7ad26d7f7d
Parents: 9bf9e1c
Author: gtully <gary.tully@gmail.com>
Authored: Fri Mar 21 13:14:40 2014 +0000
Committer: gtully <gary.tully@gmail.com>
Committed: Fri Mar 21 13:14:40 2014 +0000

----------------------------------------------------------------------
 .../activemq/bugs/TransactedStoreUsageSuspendResumeTest.java      | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/f594cdab/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
index f2910a2..e3320da 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
@@ -141,6 +141,9 @@ public class TransactedStoreUsageSuspendResumeTest {
 
         boolean allMessagesReceived = messagesReceivedCountDown.await(120, TimeUnit.SECONDS);
         assertTrue("Got all messages: " + messagesReceivedCountDown, allMessagesReceived);
+
+        // give consumers a chance to exit gracefully
+        TimeUnit.SECONDS.sleep(2);
     }
 
     private void sendMessages() throws Exception {


Mime
View raw message