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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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 interfacejava.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()
-
-