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 SocketChannel
getChannel()
AMQConnection
getConnection()
long
getLastActivity()
NioQueue
getWriteQueue()
void
sendHeader()
void
setConnection(AMQConnection connection)
void
setLastActivity(long lastActivity)
void
startReading()
void
write(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()
-
-