public interface AMQPConnectionCallback
Modifier and Type | Method and Description |
---|---|
void |
close() |
AMQPSessionCallback |
createSessionCallback(AMQPConnectionContext connection) |
AMQPConnectionContext |
getConnection() |
ServerSASL[] |
getSASLMechnisms() |
void |
onTransport(io.netty.buffer.ByteBuf bytes,
AMQPConnectionContext connection)
this is called when bytes are available to be sent to the client.
|
void |
setConnection(AMQPConnectionContext connection) |
void close()
void onTransport(io.netty.buffer.ByteBuf bytes, AMQPConnectionContext connection)
AMQPConnectionContext.outputDone(int)
after you're done with this bufferbytes
- AMQPSessionCallback createSessionCallback(AMQPConnectionContext connection)
void setConnection(AMQPConnectionContext connection)
AMQPConnectionContext getConnection()
ServerSASL[] getSASLMechnisms()
Copyright © 2016 The Apache Software Foundation. All rights reserved.