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 2014/11/17 18:30:38 UTC
[3/5] qpid-jms git commit: only allow IOException's after socket
closure to be suppressed, ensure other issues are actioned by the closer,
e.g. unexpected data being read between the final handler and shutdown
only allow IOException's after socket closure to be suppressed, ensure other issues are actioned by the closer, e.g. unexpected data being read between the final handler and shutdown
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/9b0fbc72
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/9b0fbc72
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/9b0fbc72
Branch: refs/heads/master
Commit: 9b0fbc72a58b2475b43c329a7edd1d402844be40
Parents: f9e4a6c
Author: Robert Gemmell <ro...@apache.org>
Authored: Mon Nov 17 16:52:47 2014 +0000
Committer: Robert Gemmell <ro...@apache.org>
Committed: Mon Nov 17 16:52:47 2014 +0000
----------------------------------------------------------------------
.../apache/qpid/jms/test/testpeer/TestAmqpPeerRunner.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/9b0fbc72/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeerRunner.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeerRunner.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeerRunner.java
index 5039691..6de2a3a 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeerRunner.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeerRunner.java
@@ -92,7 +92,15 @@ class TestAmqpPeerRunner implements Runnable
}
else
{
- LOGGER.debug("Caught throwable, ignoring as socket is closed: " + t);
+ if(t instanceof IOException)
+ {
+ LOGGER.debug("Caught throwable, ignoring as socket is closed: " + t, t);
+ }
+ else
+ {
+ LOGGER.debug("Caught throwable after socket is closed: " + t);
+ _throwable = t;
+ }
}
}
finally
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org