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 <[email protected]>
Authored: Mon Nov 17 16:52:47 2014 +0000
Committer: Robert Gemmell <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to