From cf22bbcd05153d214615033d1d22e33c258e5da8 Mon Sep 17 00:00:00 2001 From: msamoylych Date: Thu, 30 Mar 2017 16:16:28 +0300 Subject: [PATCH] change evt cast type IdleStateHandler triggered IdleStateEvent, not IdleState --- .../http/netty/server/NettyHttpServletHandler.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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 9d55b5c9ede..88fad7e47e7 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.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 void channelActive(ChannelHandlerContext ctx) throws Exception { @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(); } }