You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by dk...@apache.org on 2017/03/30 15:38:37 UTC
[2/4] cxf git commit: change evt cast type IdleStateHandler triggered
IdleStateEvent, not IdleState This closes #252
change evt cast type
IdleStateHandler triggered IdleStateEvent, not IdleState
This closes #252
Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/b5787370
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/b5787370
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/b5787370
Branch: refs/heads/master
Commit: b5787370fd49148f8655df5be76c103a98bf5638
Parents: ff9e62a
Author: msamoylych <ms...@users.noreply.github.com>
Authored: Thu Mar 30 16:16:28 2017 +0300
Committer: Daniel Kulp <dk...@apache.org>
Committed: Thu Mar 30 09:33:56 2017 -0400
----------------------------------------------------------------------
.../http/netty/server/NettyHttpServletHandler.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cxf/blob/b5787370/rt/transports/http-netty/netty-server/src/main/java/org/apache/cxf/transport/http/netty/server/NettyHttpServletHandler.java
----------------------------------------------------------------------
diff --git a/rt/transports/http-netty/netty-server/src/main/java/org/apache/cxf/transport/http/netty/server/NettyHttpServletHandler.java b/rt/transports/http-netty/netty-server/src/main/java/org/apache/cxf/transport/http/netty/server/NettyHttpServletHandler.java
index 9d55b5c..88fad7e 100644
--- a/rt/transports/http-netty/netty-server/src/main/java/org/apache/cxf/transport/http/netty/server/NettyHttpServletHandler.java
+++ b/rt/transports/http-netty/netty-server/src/main/java/org/apache/cxf/transport/http/netty/server/NettyHttpServletHandler.java
@@ -50,6 +50,7 @@ import io.netty.handler.codec.http.HttpResponse;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.netty.handler.codec.http.HttpVersion;
import io.netty.handler.timeout.IdleState;
+import io.netty.handler.timeout.IdleStateEvent;
import io.netty.util.CharsetUtil;
public class NettyHttpServletHandler extends ChannelInboundHandlerAdapter {
@@ -87,10 +88,10 @@ public class NettyHttpServletHandler extends ChannelInboundHandlerAdapter {
@Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
- if (evt instanceof IdleState) {
- IdleState e = (IdleState) evt;
- if (e == IdleState.READER_IDLE || e == IdleState.WRITER_IDLE) {
- LOG.log(Level.FINE, "Closing idle channel: {}", e);
+ if (evt instanceof IdleStateEvent) {
+ IdleStateEvent e = (IdleStateEvent) evt;
+ if (e.state() == IdleState.READER_IDLE || e.state() == IdleState.WRITER_IDLE) {
+ LOG.log(Level.FINE, "Closing idle channel: {}", e.state());
ctx.close();
}
}