Package com.rabbitmq.client.impl.nio
Class NioLoopContext
- java.lang.Object
-
- com.rabbitmq.client.impl.nio.NioLoopContext
-
public class NioLoopContext extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.ExecutorService
executorService
private static org.slf4j.Logger
LOGGER
(package private) java.nio.ByteBuffer
readBuffer
(package private) SelectorHolder
readSelectorState
private SocketChannelFrameHandlerFactory
socketChannelFrameHandlerFactory
private java.util.concurrent.ThreadFactory
threadFactory
(package private) java.nio.ByteBuffer
writeBuffer
(package private) SelectorHolder
writeSelectorState
-
Constructor Summary
Constructors Constructor Description NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
cleanUp()
(package private) void
initStateIfNecessary()
private void
startIoLoops()
-
-
-
Field Detail
-
LOGGER
private static final org.slf4j.Logger LOGGER
-
socketChannelFrameHandlerFactory
private final SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory
-
executorService
private final java.util.concurrent.ExecutorService executorService
-
threadFactory
private final java.util.concurrent.ThreadFactory threadFactory
-
readBuffer
final java.nio.ByteBuffer readBuffer
-
writeBuffer
final java.nio.ByteBuffer writeBuffer
-
readSelectorState
SelectorHolder readSelectorState
-
writeSelectorState
SelectorHolder writeSelectorState
-
-
Constructor Detail
-
NioLoopContext
public NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams)
-
-