NioLoop (RabbitMQ Java Client 5.16.0 API)

public class NioLoop
extends Object
implements Runnable

Logic of the NIO loop.

Constructors
Constructor and Description
`NioLoop(NioParams nioParams, NioLoopContext loopContext)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`protected void`	`dispatchIoErrorToConnection(SocketChannelFrameHandlerState state, Throwable ex)`
`protected void`	`dispatchShutdownToConnection(Runnable connectionShutdownRunnable, String connectionName)`
`protected void`	`dispatchShutdownToConnection(SocketChannelFrameHandlerState state)`
`protected void`	`handleHeartbeatFailure(SocketChannelFrameHandlerState state)`
`protected void`	`handleIoError(SocketChannelFrameHandlerState state, Throwable ex)`
`protected boolean`	`needToDispatchIoError(SocketChannelFrameHandlerState state)`
`void`	`run()`

public NioLoop(NioParams nioParams,
               NioLoopContext loopContext)

protected void handleIoError(SocketChannelFrameHandlerState state,
                             Throwable ex)

protected void handleHeartbeatFailure(SocketChannelFrameHandlerState state)

protected boolean needToDispatchIoError(SocketChannelFrameHandlerState state)

protected void dispatchIoErrorToConnection(SocketChannelFrameHandlerState state,
                                           Throwable ex)

protected void dispatchShutdownToConnection(SocketChannelFrameHandlerState state)

protected void dispatchShutdownToConnection(Runnable connectionShutdownRunnable,
                                            String connectionName)

Class NioLoop