Package com.rabbitmq.client.impl.nio
Class NioLoop
java.lang.Object
com.rabbitmq.client.impl.nio.NioLoop
- All Implemented Interfaces:
Runnable
Logic of the NIO loop.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ExecutorService
private final NioLoopContext
private static final org.slf4j.Logger
private final NioParams
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected void
protected void
dispatchShutdownToConnection
(Runnable connectionShutdownRunnable, String connectionName) private ExecutorService
protected void
protected void
handleIoError
(SocketChannelFrameHandlerState state, Throwable ex) protected boolean
void
run()
private ThreadFactory
-
Field Details
-
LOGGER
private static final org.slf4j.Logger LOGGER -
context
-
nioParams
-
connectionShutdownExecutor
-
-
Constructor Details
-
NioLoop
-
-
Method Details