Package com.rabbitmq.client.impl.nio
Class NioLoop
- java.lang.Object
-
- com.rabbitmq.client.impl.nio.NioLoop
-
-
Constructor Summary
Constructors Constructor Description NioLoop(NioParams nioParams, NioLoopContext loopContext)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
dispatchIoErrorToConnection(SocketChannelFrameHandlerState state, Throwable ex)
protected void
dispatchShutdownToConnection(SocketChannelFrameHandlerState state)
protected void
dispatchShutdownToConnection(Runnable connectionShutdownRunnable, String connectionName)
protected void
handleHeartbeatFailure(SocketChannelFrameHandlerState state)
protected void
handleIoError(SocketChannelFrameHandlerState state, Throwable ex)
protected boolean
needToDispatchIoError(SocketChannelFrameHandlerState state)
void
run()
-
-
-
Constructor Detail
-
NioLoop
public NioLoop(NioParams nioParams, NioLoopContext loopContext)
-
-
Method Detail
-
handleIoError
protected void handleIoError(SocketChannelFrameHandlerState state, Throwable ex)
-
handleHeartbeatFailure
protected void handleHeartbeatFailure(SocketChannelFrameHandlerState state)
-
needToDispatchIoError
protected boolean needToDispatchIoError(SocketChannelFrameHandlerState state)
-
dispatchIoErrorToConnection
protected void dispatchIoErrorToConnection(SocketChannelFrameHandlerState state, Throwable ex)
-
dispatchShutdownToConnection
protected void dispatchShutdownToConnection(SocketChannelFrameHandlerState state)
-
-