Class SocketChannelFrameHandlerState

java.lang.Object

com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState

public class SocketChannelFrameHandlerState
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final SocketChannel	channel
(package private) final ByteBuffer	cipherIn	inbound data (ciphered if TLS is on)
(package private) final ByteBuffer	cipherOut	outbound net data (ciphered if TLS is on)
private AMQConnection	connection
(package private) final FrameBuilder	frameBuilder
private long	lastActivity	should be used only in the NIO read thread
private static final org.slf4j.Logger	LOGGER
(package private) final DataOutputStream	outputStream
(package private) final ByteBuffer	plainIn	inbound app data (deciphered if TLS is on)
(package private) final ByteBuffer	plainOut	outbound app data (to be crypted if TLS is on)
private final SelectorHolder	readSelectorState
private static final int	SOCKET_CLOSING_TIMEOUT	Time to linger before closing the socket forcefully.
(package private) final boolean	ssl
(package private) final SSLEngine	sslEngine
private final NioQueue	writeQueue
private final SelectorHolder	writeSelectorState

Constructor Summary

Constructors

Constructor	Description
SocketChannelFrameHandlerState(SocketChannel channel, NioLoopContext nioLoopsState, NioParams nioParams, SSLEngine sslEngine, int maxFramePayloadSize)

Method Summary

Modifier and Type	Method	Description
(package private) void	close()
(package private) boolean	continueReading()
(package private) void	endWriteSequence()
SocketChannel	getChannel()
AMQConnection	getConnection()
long	getLastActivity()
NioQueue	getWriteQueue()
(package private) void	prepareForReadSequence()
(package private) void	prepareForWriteSequence()
void	sendHeader()
private void	sendWriteRequest(WriteRequest writeRequest)
void	setConnection(AMQConnection connection)
void	setLastActivity(long lastActivity)
void	startReading()
void	write(Frame frame)

Methods inherited from class Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

SOCKET_CLOSING_TIMEOUT

private static final int SOCKET_CLOSING_TIMEOUT

Time to linger before closing the socket forcefully.

See Also:

• Constant Field Values

channel

private final SocketChannel channel

writeQueue

private final NioQueue writeQueue

connection

private volatile AMQConnection connection

lastActivity

private long lastActivity

should be used only in the NIO read thread

writeSelectorState

private final SelectorHolder writeSelectorState

readSelectorState

private final SelectorHolder readSelectorState

ssl

final boolean ssl

sslEngine

final SSLEngine sslEngine

plainOut

final ByteBuffer plainOut

outbound app data (to be crypted if TLS is on)

plainIn

final ByteBuffer plainIn

inbound app data (deciphered if TLS is on)

cipherOut

final ByteBuffer cipherOut

outbound net data (ciphered if TLS is on)

cipherIn

final ByteBuffer cipherIn

inbound data (ciphered if TLS is on)

outputStream

final DataOutputStream outputStream

frameBuilder

final FrameBuilder frameBuilder

Constructor Details

SocketChannelFrameHandlerState

public SocketChannelFrameHandlerState(SocketChannel channel,
 NioLoopContext nioLoopsState,
 NioParams nioParams,
 SSLEngine sslEngine,
 int maxFramePayloadSize)

Method Details

getChannel

public SocketChannel getChannel()

getWriteQueue

public NioQueue getWriteQueue()

sendHeader

public void sendHeader()
                throws IOException

Throws:

IOException

write

public void write(Frame frame)
           throws IOException

Throws:

IOException

sendWriteRequest

private void sendWriteRequest(WriteRequest writeRequest)
                       throws IOException

Throws:

IOException

startReading

public void startReading()

getConnection

public AMQConnection getConnection()

setConnection

public void setConnection(AMQConnection connection)

setLastActivity

public void setLastActivity(long lastActivity)

getLastActivity

public long getLastActivity()

prepareForWriteSequence

void prepareForWriteSequence()

endWriteSequence

void endWriteSequence()

prepareForReadSequence

void prepareForReadSequence()
                     throws IOException

Throws:

IOException

continueReading

boolean continueReading()
                 throws IOException

Throws:

IOException

close

void close()
    throws IOException

Throws:

IOException