Package com.rabbitmq.client.impl.nio

Class NioLoop

java.lang.Object

com.rabbitmq.client.impl.nio.NioLoop

All Implemented Interfaces:

java.lang.Runnable

public class NioLoop
extends java.lang.Object
implements java.lang.Runnable

Logic of the NIO loop.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
NioLoop(NioParams nioParams, NioLoopContext loopContext)

Method Summary

Modifier and Type	Method	Description
protected void	dispatchIoErrorToConnection(SocketChannelFrameHandlerState state, java.lang.Throwable ex)
protected void	dispatchShutdownToConnection(SocketChannelFrameHandlerState state)
protected void	dispatchShutdownToConnection(java.lang.Runnable connectionShutdownRunnable, java.lang.String connectionName)
private java.util.concurrent.ExecutorService	executorService()
protected void	handleHeartbeatFailure(SocketChannelFrameHandlerState state)
protected void	handleIoError(SocketChannelFrameHandlerState state, java.lang.Throwable ex)
protected boolean	needToDispatchIoError(SocketChannelFrameHandlerState state)
void	run()
private java.util.concurrent.ThreadFactory	threadFactory()

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

context

private final NioLoopContext context

nioParams

private final NioParams nioParams

connectionShutdownExecutor

private final java.util.concurrent.ExecutorService connectionShutdownExecutor

Constructor Detail

NioLoop

public NioLoop(NioParams nioParams,
               NioLoopContext loopContext)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

handleIoError

protected void handleIoError(SocketChannelFrameHandlerState state,
                             java.lang.Throwable ex)

handleHeartbeatFailure

protected void handleHeartbeatFailure(SocketChannelFrameHandlerState state)

needToDispatchIoError

protected boolean needToDispatchIoError(SocketChannelFrameHandlerState state)

dispatchIoErrorToConnection

protected void dispatchIoErrorToConnection(SocketChannelFrameHandlerState state,
                                           java.lang.Throwable ex)

dispatchShutdownToConnection

protected void dispatchShutdownToConnection(SocketChannelFrameHandlerState state)

dispatchShutdownToConnection

protected void dispatchShutdownToConnection(java.lang.Runnable connectionShutdownRunnable,
                                            java.lang.String connectionName)

executorService

private java.util.concurrent.ExecutorService executorService()

threadFactory

private java.util.concurrent.ThreadFactory threadFactory()