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.ExecutorServiceexecutorServiceprivate static org.slf4j.LoggerLOGGER(package private) java.nio.ByteBufferreadBuffer(package private) SelectorHolderreadSelectorStateprivate SocketChannelFrameHandlerFactorysocketChannelFrameHandlerFactoryprivate java.util.concurrent.ThreadFactorythreadFactory(package private) java.nio.ByteBufferwriteBuffer(package private) SelectorHolderwriteSelectorState
-
Constructor Summary
Constructors Constructor Description NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected booleancleanUp()(package private) voidinitStateIfNecessary()private voidstartIoLoops()
-
-
-
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)
-
-