Package com.rabbitmq.client.impl.nio

Class NioLoop

java.lang.Object

com.rabbitmq.client.impl.nio.NioLoop

All Implemented Interfaces:

Runnable

public class NioLoop
extends Object
implements Runnable

Logic of the NIO loop.

Constructor Summary

Constructors

Constructor	Description
NioLoop(NioParams nioParams, NioLoopContext loopContext)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NioLoop

public NioLoop(NioParams nioParams,
 NioLoopContext loopContext)

Method Details

run

public void run()

Specified by:

run in interface Runnable

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)

dispatchShutdownToConnection

protected void dispatchShutdownToConnection(Runnable connectionShutdownRunnable,
 String connectionName)