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.

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	connectionShutdownExecutor
private final NioLoopContext	context
private static final org.slf4j.Logger	LOGGER
private final NioParams	nioParams

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)
private ExecutorService	executorService()
protected void	handleHeartbeatFailure(SocketChannelFrameHandlerState state)
protected void	handleIoError(SocketChannelFrameHandlerState state, Throwable ex)
protected boolean	needToDispatchIoError(SocketChannelFrameHandlerState state)
void	run()
private ThreadFactory	threadFactory()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

context

private final NioLoopContext context

nioParams

private final NioParams nioParams

connectionShutdownExecutor

private final ExecutorService connectionShutdownExecutor

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)

executorService

private ExecutorService executorService()

threadFactory

private ThreadFactory threadFactory()