You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2015/01/04 02:45:00 UTC
[2/2] camel git commit: CAMEL-8193 Fixed the IllegalStateException of
camel-netty with thanks to Mark.
CAMEL-8193 Fixed the IllegalStateException of camel-netty with thanks to Mark.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/21e9041c
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/21e9041c
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/21e9041c
Branch: refs/heads/master
Commit: 21e9041ccb18902cc3f4c14b7fc24e8c823d5250
Parents: ceb35df
Author: Willem Jiang <wi...@gmail.com>
Authored: Sun Jan 4 09:38:58 2015 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Sun Jan 4 09:40:05 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/camel/component/netty/NettyHelper.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/21e9041c/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java
----------------------------------------------------------------------
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java
index b9368fa..aabadd2 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyHelper.java
@@ -111,7 +111,11 @@ public final class NettyHelper {
public static void close(Channel channel) {
if (channel != null) {
LOG.trace("Closing channel: {}", channel);
- channel.close().syncUninterruptibly();
+ channel.close().addListener(new ChannelFutureListener() {
+ public void operationComplete(ChannelFuture future) {
+ LOG.trace("Channel closed: {}", future.getChannel());
+ }
+ });
}
}