summaryrefslogtreecommitdiff
path: root/java/client/src/test/java/org/apache/qpid/client/ResetMessageListenerTest.java
diff options
context:
space:
mode:
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.java11
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)
{