public interface AMQPConnectionContext
Modifier and Type | Method and Description |
---|---|
int |
capacity() |
boolean |
checkDataReceived() |
void |
close() |
void |
flush() |
long |
getCreationTime() |
Object |
getLock() |
SASLResult |
getSASLResult() |
void |
inputBuffer(io.netty.buffer.ByteBuf buffer)
This is for the Remoting layer to push bytes on the AMQP Connection
The buffer readerIndex should be at the latest read byte after this method is called
|
boolean |
isSyncOnFlush()
Even though we are currently always sending packets asynchronsouly
we have a possibility to start trusting on the network flow control
and always sync on the send of the packet
This is for future use and should be kept returning false.
|
void |
outputDone(int numberOfBytes)
To be called when the bytes were sent down the stream (flushed on the socket for example)
|
void close()
Object getLock()
boolean checkDataReceived()
long getCreationTime()
SASLResult getSASLResult()
boolean isSyncOnFlush()
int capacity()
void inputBuffer(io.netty.buffer.ByteBuf buffer)
void flush()
void outputDone(int numberOfBytes)
numberOfBytes
- Copyright © 2016 The Apache Software Foundation. All rights reserved.