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

This commit is contained in:
gtully 2014-03-21 13:14:40 +00:00
parent 9bf9e1c052
commit f594cdab10
1 changed files with 3 additions and 0 deletions

View File

@ -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 {