diff options
Diffstat (limited to 'java/systests/src/main/java/org/apache/qpid/client/ResetMessageListenerTest.java')
-rw-r--r-- | java/systests/src/main/java/org/apache/qpid/client/ResetMessageListenerTest.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/client/ResetMessageListenerTest.java b/java/systests/src/main/java/org/apache/qpid/client/ResetMessageListenerTest.java index 40a0d32b01..303da29389 100644 --- a/java/systests/src/main/java/org/apache/qpid/client/ResetMessageListenerTest.java +++ b/java/systests/src/main/java/org/apache/qpid/client/ResetMessageListenerTest.java @@ -135,7 +135,7 @@ public class ResetMessageListenerTest extends QpidBrokerTestCase try { assertTrue("Did not receive all first batch of messages", - _allFirstMessagesSent.await(MSG_COUNT, TimeUnit.SECONDS)); + _allFirstMessagesSent.await(1000, TimeUnit.MILLISECONDS)); _logger.info("Received first batch of messages"); } catch (InterruptedException e) @@ -212,7 +212,7 @@ public class ResetMessageListenerTest extends QpidBrokerTestCase try { - assertTrue(_allSecondMessagesSent.await(MSG_COUNT, TimeUnit.SECONDS)); + assertTrue(_allSecondMessagesSent.await(1000, TimeUnit.MILLISECONDS)); } catch (InterruptedException e) { |