Package com.rabbitmq.client.impl.nio
Class SocketChannelFrameHandlerState
- java.lang.Object
-
- com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerState
-
public class SocketChannelFrameHandlerState extends Object
-
-
Constructor Summary
Constructors Constructor Description SocketChannelFrameHandlerState(SocketChannel channel, NioLoopContext nioLoopsState, NioParams nioParams, SSLEngine sslEngine)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SocketChannelgetChannel()AMQConnectiongetConnection()longgetLastActivity()NioQueuegetWriteQueue()voidsendHeader()voidsetConnection(AMQConnection connection)voidsetLastActivity(long lastActivity)voidstartReading()voidwrite(Frame frame)
-
-
-
Constructor Detail
-
SocketChannelFrameHandlerState
public SocketChannelFrameHandlerState(SocketChannel channel, NioLoopContext nioLoopsState, NioParams nioParams, SSLEngine sslEngine)
-
-
Method Detail
-
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
-
startReading
public void startReading()
-
getConnection
public AMQConnection getConnection()
-
setConnection
public void setConnection(AMQConnection connection)
-
setLastActivity
public void setLastActivity(long lastActivity)
-
getLastActivity
public long getLastActivity()
-
-