QPIDJMS-95: add some extra trace logging, make exception message slightly clearer
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/e46354bd Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/e46354bd Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/e46354bd Branch: refs/heads/master Commit: e46354bd724f10a6e670ebd821987b99cbf2e943 Parents: 2d51c8c Author: Robert Gemmell <[email protected]> Authored: Fri Aug 21 15:28:04 2015 +0100 Committer: Robert Gemmell <[email protected]> Committed: Fri Aug 21 18:44:54 2015 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java | 2 +- .../org/apache/qpid/jms/transports/netty/NettyTcpTransport.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e46354bd/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java index 15c3cc2..3a2e709 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java @@ -736,7 +736,7 @@ public class AmqpProvider implements Provider, TransportListener { public void run() { LOG.debug("Transport connection remotely closed"); if (!closed.get()) { - fireProviderException(new IOException("Connection remotely closed.")); + fireProviderException(new IOException("Transport connection remotely closed.")); if (connection != null) { connection.closed(); } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e46354bd/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java index 08be1f7..8035161 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyTcpTransport.java @@ -294,6 +294,7 @@ public class NettyTcpTransport implements Transport { LOG.trace("Channel has gone inactive! Channel is {}", context.channel()); if (!closed.get()) { connected.set(false); + LOG.trace("Firing onTransportClosed listener"); listener.onTransportClosed(); } } @@ -303,6 +304,7 @@ public class NettyTcpTransport implements Transport { LOG.trace("Exception on channel! Channel is {}", context.channel()); if (!closed.get()) { connected.set(false); + LOG.trace("Firing onTransportError listener"); listener.onTransportError(cause); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
