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, int maxFramePayloadSize)

Method Summary

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)

Methods inherited from class java.lang.Object

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

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

startReading

public void startReading()

getConnection

public AMQConnection getConnection()

setConnection

public void setConnection(AMQConnection connection)

setLastActivity

public void setLastActivity(long lastActivity)

getLastActivity

public long getLastActivity()