java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
io.netty.channel.ChannelDuplexHandler
io.netty.handler.timeout.IdleStateHandler
io.netty.handler.timeout.ReadTimeoutHandler
org.neo4j.driver.internal.async.inbound.ConnectTimeoutHandler
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
,io.netty.channel.ChannelOutboundHandler
public class ConnectTimeoutHandler
extends io.netty.handler.timeout.ReadTimeoutHandler
Handler needed to limit amount of time connection performs TLS and Bolt handshakes.
It should only be used when connection is established and removed from the pipeline afterwards.
Otherwise it will make long running queries fail.
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
io.netty.channel.ChannelHandler.Sharable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
readTimedOut
(io.netty.channel.ChannelHandlerContext ctx) Methods inherited from class io.netty.handler.timeout.ReadTimeoutHandler
channelIdle
Methods inherited from class io.netty.handler.timeout.IdleStateHandler
channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, getAllIdleTimeInMillis, getReaderIdleTimeInMillis, getWriterIdleTimeInMillis, handlerAdded, handlerRemoved, newIdleStateEvent, resetReadTimeout, resetWriteTimeout, write
Methods inherited from class io.netty.channel.ChannelDuplexHandler
bind, close, connect, deregister, disconnect, flush, read
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, isSharable
-
Constructor Details
-
ConnectTimeoutHandler
public ConnectTimeoutHandler(long timeoutMillis)
-
-
Method Details
-
readTimedOut
protected void readTimedOut(io.netty.channel.ChannelHandlerContext ctx) - Overrides:
readTimedOut
in classio.netty.handler.timeout.ReadTimeoutHandler
-