You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2015/12/18 00:38:55 UTC
qpid-jms git commit: QPIDJMS-144 Add a couple more logs in the test
server
Repository: qpid-jms
Updated Branches:
refs/heads/master f89097978 -> d9f60377f
QPIDJMS-144 Add a couple more logs in the test server
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/d9f60377
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/d9f60377
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/d9f60377
Branch: refs/heads/master
Commit: d9f60377fc97b2ff1cc5f0a5e41882a437e14811
Parents: f890979
Author: Timothy Bish <ta...@gmail.com>
Authored: Thu Dec 17 18:38:49 2015 -0500
Committer: Timothy Bish <ta...@gmail.com>
Committed: Thu Dec 17 18:38:49 2015 -0500
----------------------------------------------------------------------
.../org/apache/qpid/jms/transports/netty/NettyEchoServer.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/d9f60377/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyEchoServer.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyEchoServer.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyEchoServer.java
index 4f100a9..7f45b7c 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyEchoServer.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/transports/netty/NettyEchoServer.java
@@ -153,6 +153,7 @@ public class NettyEchoServer implements AutoCloseable {
@Override
public void channelActive(final ChannelHandlerContext ctx) {
+ LOG.info("New active channel: {}", ctx.channel());
SslHandler handler = ctx.pipeline().get(SslHandler.class);
if (handler != null) {
handler.handshakeFuture().addListener(new GenericFutureListener<Future<Channel>>() {
@@ -170,6 +171,7 @@ public class NettyEchoServer implements AutoCloseable {
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+ LOG.info("channel has gone inactive: {}", ctx.channel());
ctx.close();
}
@@ -185,6 +187,7 @@ public class NettyEchoServer implements AutoCloseable {
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
+ LOG.info("Exception caught on channel: {}", ctx.channel());
// Close the connection when an exception is raised.
cause.printStackTrace();
ctx.close();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org