You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2016/09/15 17:17:04 UTC
[2/2] qpid-jms git commit: QPIDJMS-207: fix some more timeouts
QPIDJMS-207: fix some more timeouts
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/9903b1c6
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/9903b1c6
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/9903b1c6
Branch: refs/heads/master
Commit: 9903b1c6d8b234ab76cd5f64ba229303eaff4d49
Parents: 34c6a7d
Author: Robert Gemmell <ro...@apache.org>
Authored: Thu Sep 15 18:10:00 2016 +0100
Committer: Robert Gemmell <ro...@apache.org>
Committed: Thu Sep 15 18:10:00 2016 +0100
----------------------------------------------------------------------
.../integration/ProducerIntegrationTest.java | 20 ++++++++++----------
.../jms/integration/SessionIntegrationTest.java | 4 ++--
2 files changed, 12 insertions(+), 12 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9903b1c6/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ProducerIntegrationTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ProducerIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ProducerIntegrationTest.java
index 9bca0cd..75d8ee4 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ProducerIntegrationTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ProducerIntegrationTest.java
@@ -1259,11 +1259,11 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
try {
producer.send(message, listener);
} catch (Throwable error) {
- LOG.info("Caught expected error: {}", error.getMessage());
+ LOG.info("Caught unexpected error: {}", error.getMessage());
fail("Send should not fail for async.");
}
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNotNull(listener.exception);
assertTrue(listener.exception instanceof JmsSendTimedOutException);
assertNotNull(listener.message);
@@ -1934,7 +1934,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
producer.send(message, listener);
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNull(listener.exception);
assertNotNull(listener.message);
assertTrue(listener.message instanceof TextMessage);
@@ -1969,7 +1969,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
producer.send(message, listener);
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNull(listener.exception);
assertNotNull(listener.message);
assertTrue(listener.message instanceof BytesMessage);
@@ -2063,7 +2063,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
fail("No expected exception for this send.");
}
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNotNull(listener.exception);
assertNotNull(listener.message);
assertTrue(listener.message instanceof TextMessage);
@@ -2079,7 +2079,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
fail("No expected exception for this send.");
}
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNull(listener.exception);
assertNotNull(listener.message);
assertTrue(listener.message instanceof TextMessage);
@@ -2126,7 +2126,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
producer.send(message, listener);
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNull(listener.exception);
assertNotNull(listener.message);
assertTrue(listener.message instanceof TextMessage);
@@ -2175,7 +2175,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
producer.send(message, listener);
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNull(listener.exception);
assertNotNull(listener.message);
assertNotNull(closeError.get());
@@ -2246,7 +2246,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
producer.send(message, listener);
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNull(listener.exception);
assertNotNull(listener.message);
assertNotNull(commitError.get());
@@ -2317,7 +2317,7 @@ public class ProducerIntegrationTest extends QpidJmsTestCase {
producer.send(message, listener);
- assertTrue("Did not get async callback", listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue("Did not get async callback", listener.awaitCompletion(5, TimeUnit.SECONDS));
assertNull(listener.exception);
assertNotNull(listener.message);
assertNotNull(rollback.get());
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9903b1c6/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java
index 3cc2bab..e352b7d 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java
@@ -1744,10 +1744,10 @@ public class SessionIntegrationTest extends QpidJmsTestCase {
fail("No expected exception for this send.");
}
- testPeer.waitForAllHandlersToComplete(1000);
+ testPeer.waitForAllHandlersToComplete(2000);
// Verify the producer gets marked closed
- assertTrue(listener.awaitCompletion(2000, TimeUnit.SECONDS));
+ assertTrue(listener.awaitCompletion(5, TimeUnit.SECONDS));
assertEquals(MSG_COUNT, listener.errorCount);
assertEquals(0, listener.successCount);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org