Repository: qpid-jms Updated Branches: refs/heads/master a9386dac5 -> c695388b1
Don't send error or close events if transport is already closed. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/784025ac Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/784025ac Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/784025ac Branch: refs/heads/master Commit: 784025ac01a79e009f0131fcc7d851528d935837 Parents: a9386da Author: Timothy Bish <tabish...@gmail.com> Authored: Tue Sep 30 18:23:45 2014 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Tue Sep 30 18:23:45 2014 -0400 ---------------------------------------------------------------------- .../org/apache/qpid/jms/transports/TcpTransport.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/784025ac/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/TcpTransport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/TcpTransport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/TcpTransport.java index 121084c..0f2cca5 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/TcpTransport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/TcpTransport.java @@ -109,16 +109,20 @@ public class TcpTransport implements Transport { socket.closeHandler(new Handler<Void>() { @Override public void handle(Void event) { - connected.set(false); - listener.onTransportClosed(); + if (!closed.get()) { + connected.set(false); + listener.onTransportClosed(); + } } }); socket.exceptionHandler(new Handler<Throwable>() { @Override public void handle(Throwable event) { - connected.set(false); - listener.onTransportError(event); + if (!closed.get()) { + connected.set(false); + listener.onTransportError(event); + } } }); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
