Package com.rabbitmq.client.impl.nio

Class NioLoopContext

java.lang.Object

com.rabbitmq.client.impl.nio.NioLoopContext

public class NioLoopContext
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	executorService
private static final org.slf4j.Logger	LOGGER
(package private) final ByteBuffer	readBuffer
(package private) SelectorHolder	readSelectorState
private final SocketChannelFrameHandlerFactory	socketChannelFrameHandlerFactory
private final ThreadFactory	threadFactory
(package private) final ByteBuffer	writeBuffer
(package private) SelectorHolder	writeSelectorState

Constructor Summary

Constructors

Constructor	Description
NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams)

Method Summary

Modifier and Type	Method	Description
protected boolean	cleanUp()
(package private) void	initStateIfNecessary()
private void	startIoLoops()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

socketChannelFrameHandlerFactory

private final SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory

executorService

private final ExecutorService executorService

threadFactory

private final ThreadFactory threadFactory

readBuffer

final ByteBuffer readBuffer

writeBuffer

final ByteBuffer writeBuffer

readSelectorState

SelectorHolder readSelectorState

writeSelectorState

SelectorHolder writeSelectorState

Constructor Details

NioLoopContext

public NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory,
 NioParams nioParams)

Method Details

initStateIfNecessary

void initStateIfNecessary()
                   throws IOException

Throws:

IOException

startIoLoops

private void startIoLoops()

cleanUp

protected boolean cleanUp()