Package com.rabbitmq.client.impl.nio
Class SocketChannelFrameHandlerState
java.lang.Object
com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final SocketChannel
(package private) final ByteBuffer
inbound data (ciphered if TLS is on)(package private) final ByteBuffer
outbound net data (ciphered if TLS is on)private AMQConnection
(package private) final FrameBuilder
private long
should be used only in the NIO read threadprivate static final org.slf4j.Logger
(package private) final DataOutputStream
(package private) final ByteBuffer
inbound app data (deciphered if TLS is on)(package private) final ByteBuffer
outbound app data (to be crypted if TLS is on)private final SelectorHolder
private static final int
Time to linger before closing the socket forcefully.(package private) final boolean
(package private) final SSLEngine
private final NioQueue
private final SelectorHolder
-
Constructor Summary
ConstructorsConstructorDescriptionSocketChannelFrameHandlerState
(SocketChannel channel, NioLoopContext nioLoopsState, NioParams nioParams, SSLEngine sslEngine, int maxFramePayloadSize) -
Method Summary
Modifier and TypeMethodDescription(package private) void
close()
(package private) boolean
(package private) void
long
(package private) void
(package private) void
void
private void
sendWriteRequest
(WriteRequest writeRequest) void
setConnection
(AMQConnection connection) void
setLastActivity
(long lastActivity) void
void
-
Field Details
-
LOGGER
private static final org.slf4j.Logger LOGGER -
SOCKET_CLOSING_TIMEOUT
private static final int SOCKET_CLOSING_TIMEOUTTime to linger before closing the socket forcefully.- See Also:
-
channel
-
writeQueue
-
connection
-
lastActivity
private long lastActivityshould be used only in the NIO read thread -
writeSelectorState
-
readSelectorState
-
ssl
final boolean ssl -
sslEngine
-
plainOut
outbound app data (to be crypted if TLS is on) -
plainIn
inbound app data (deciphered if TLS is on) -
cipherOut
outbound net data (ciphered if TLS is on) -
cipherIn
inbound data (ciphered if TLS is on) -
outputStream
-
frameBuilder
-
-
Constructor Details
-
SocketChannelFrameHandlerState
public SocketChannelFrameHandlerState(SocketChannel channel, NioLoopContext nioLoopsState, NioParams nioParams, SSLEngine sslEngine, int maxFramePayloadSize)
-
-
Method Details
-
getChannel
-
getWriteQueue
-
sendHeader
- Throws:
IOException
-
write
- Throws:
IOException
-
sendWriteRequest
- Throws:
IOException
-
startReading
public void startReading() -
getConnection
-
setConnection
-
setLastActivity
public void setLastActivity(long lastActivity) -
getLastActivity
public long getLastActivity() -
prepareForWriteSequence
void prepareForWriteSequence() -
endWriteSequence
void endWriteSequence() -
prepareForReadSequence
- Throws:
IOException
-
continueReading
- Throws:
IOException
-
close
- Throws:
IOException
-