diff options
Diffstat (limited to 'java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java')
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java b/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java index 21f3e273aa..81d9a39dd3 100644 --- a/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java +++ b/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java @@ -116,6 +116,7 @@ public class ResetMessageListenerTest extends TestCase { _producer.send(_producerSession.createTextMessage("Message " + msg)); } +// Thread.sleep(120000); } @@ -247,6 +248,14 @@ public class ResetMessageListenerTest extends TestCase { _producer.send(_producerSession.createTextMessage("Message " + msg)); } +// try +// { +// Thread.sleep(120000); +// } +// catch (InterruptedException e) +// { +// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates. +// } } catch (JMSException e) { @@ -257,7 +266,7 @@ public class ResetMessageListenerTest extends TestCase try { - _allSecondMessagesSent.await(5000, TimeUnit.MILLISECONDS); + _allSecondMessagesSent.await(500000, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { |