public class ActiveMQProtonConnectionCallback extends Object implements AMQPConnectionCallback
Modifier and Type | Field and Description |
---|---|
protected AMQPConnectionContext |
amqpConnection |
protected ActiveMQProtonRemotingConnection |
protonConnectionDelegate |
Constructor and Description |
---|
ActiveMQProtonConnectionCallback(ProtonProtocolManager manager,
Connection connection,
Executor closeExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
AMQPSessionCallback |
createSessionCallback(AMQPConnectionContext connection) |
AMQPConnectionContext |
getConnection() |
Executor |
getExeuctor() |
ActiveMQProtonRemotingConnection |
getProtonConnectionDelegate() |
ServerSASL[] |
getSASLMechnisms() |
void |
onTransport(io.netty.buffer.ByteBuf byteBuf,
AMQPConnectionContext amqpConnection)
this is called when bytes are available to be sent to the client.
|
void |
setConnection(AMQPConnectionContext connection) |
void |
setProtonConnectionDelegate(ActiveMQProtonRemotingConnection protonConnectionDelegate) |
protected ActiveMQProtonRemotingConnection protonConnectionDelegate
protected AMQPConnectionContext amqpConnection
public ActiveMQProtonConnectionCallback(ProtonProtocolManager manager, Connection connection, Executor closeExecutor)
public ServerSASL[] getSASLMechnisms()
getSASLMechnisms
in interface AMQPConnectionCallback
public void close()
close
in interface AMQPConnectionCallback
public Executor getExeuctor()
public void setConnection(AMQPConnectionContext connection)
setConnection
in interface AMQPConnectionCallback
public AMQPConnectionContext getConnection()
getConnection
in interface AMQPConnectionCallback
public ActiveMQProtonRemotingConnection getProtonConnectionDelegate()
public void setProtonConnectionDelegate(ActiveMQProtonRemotingConnection protonConnectionDelegate)
public void onTransport(io.netty.buffer.ByteBuf byteBuf, AMQPConnectionContext amqpConnection)
AMQPConnectionCallback
AMQPConnectionContext.outputDone(int)
after you're done with this bufferonTransport
in interface AMQPConnectionCallback
public AMQPSessionCallback createSessionCallback(AMQPConnectionContext connection)
createSessionCallback
in interface AMQPConnectionCallback
Copyright © 2016 The Apache Software Foundation. All rights reserved.