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/11/09 16:05:00 UTC
qpid-jms git commit: QPIDJMS-207: improve output to help diagnosing
failure cause
Repository: qpid-jms
Updated Branches:
refs/heads/master ae66f1038 -> c8f0b7e91
QPIDJMS-207: improve output to help diagnosing failure cause
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/c8f0b7e9
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/c8f0b7e9
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/c8f0b7e9
Branch: refs/heads/master
Commit: c8f0b7e91c0a3cb8a801e167b9efcac544875f5e
Parents: ae66f10
Author: Robert Gemmell <ro...@apache.org>
Authored: Wed Nov 9 16:04:32 2016 +0000
Committer: Robert Gemmell <ro...@apache.org>
Committed: Wed Nov 9 16:04:32 2016 +0000
----------------------------------------------------------------------
.../qpid/jms/integration/ConsumerIntegrationTest.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/c8f0b7e9/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java
index ff12293..be866a0 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConsumerIntegrationTest.java
@@ -1022,8 +1022,15 @@ public class ConsumerIntegrationTest extends QpidJmsTestCase {
boolean await = latch.await(3000, TimeUnit.MILLISECONDS);
assertTrue("Messages not received within given timeout. Count remaining: " + latch.getCount(), await);
- assertNotNull(asyncError.get());
- assertTrue(asyncError.get() instanceof IllegalStateException);
+ Exception ex = asyncError.get();
+
+ assertNotNull("Expected an exception", ex);
+
+ boolean expectedType = ex instanceof IllegalStateException;
+ if(!expectedType) {
+ LOG.error("Unexpected exception type", ex);
+ }
+ assertTrue("Got unexpected exception type: " + ex, expectedType);
testPeer.waitForAllHandlersToComplete(2000);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org