Package com.rabbitmq.client.impl.nio
Class NioLoopContext
java.lang.Object
com.rabbitmq.client.impl.nio.NioLoopContext
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ExecutorService
private static final org.slf4j.Logger
(package private) final ByteBuffer
(package private) SelectorHolder
private final SocketChannelFrameHandlerFactory
private final ThreadFactory
(package private) final ByteBuffer
(package private) SelectorHolder
-
Constructor Summary
ConstructorsConstructorDescriptionNioLoopContext
(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams) -
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
cleanUp()
(package private) void
private void
-
Field Details
-
LOGGER
private static final org.slf4j.Logger LOGGER -
socketChannelFrameHandlerFactory
-
executorService
-
threadFactory
-
readBuffer
-
writeBuffer
-
readSelectorState
SelectorHolder readSelectorState -
writeSelectorState
SelectorHolder writeSelectorState
-
-
Constructor Details
-
NioLoopContext
public NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams)
-
-
Method Details
-
initStateIfNecessary
- Throws:
IOException
-
startIoLoops
private void startIoLoops() -
cleanUp
protected boolean cleanUp()
-