org.apache.activemq.artemis.core.protocol.proton.plug

Class ActiveMQProtonConnectionCallback

java.lang.Object

org.apache.activemq.artemis.core.protocol.proton.plug.ActiveMQProtonConnectionCallback

All Implemented Interfaces:

AMQPConnectionCallback

public class ActiveMQProtonConnectionCallback
extends Object
implements AMQPConnectionCallback

Field Summary

Fields

Modifier and Type	Field and Description
protected AMQPConnectionContext	amqpConnection
protected ActiveMQProtonRemotingConnection	protonConnectionDelegate

Constructor Summary

Constructors

Constructor and Description
ActiveMQProtonConnectionCallback(ProtonProtocolManager manager, Connection connection, Executor closeExecutor)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

protonConnectionDelegate

protected ActiveMQProtonRemotingConnection protonConnectionDelegate

amqpConnection

protected AMQPConnectionContext amqpConnection

Constructor Detail

ActiveMQProtonConnectionCallback

public ActiveMQProtonConnectionCallback(ProtonProtocolManager manager,
                                        Connection connection,
                                        Executor closeExecutor)

Method Detail

getSASLMechnisms

public ServerSASL[] getSASLMechnisms()

Specified by:

getSASLMechnisms in interface AMQPConnectionCallback

close

public void close()

Specified by:

close in interface AMQPConnectionCallback

getExeuctor

public Executor getExeuctor()

setConnection

public void setConnection(AMQPConnectionContext connection)

Specified by:

setConnection in interface AMQPConnectionCallback

getConnection

public AMQPConnectionContext getConnection()

Specified by:

getConnection in interface AMQPConnectionCallback

getProtonConnectionDelegate

public ActiveMQProtonRemotingConnection getProtonConnectionDelegate()

setProtonConnectionDelegate

public void setProtonConnectionDelegate(ActiveMQProtonRemotingConnection protonConnectionDelegate)

onTransport

public void onTransport(io.netty.buffer.ByteBuf byteBuf,
                        AMQPConnectionContext amqpConnection)

Description copied from interface: AMQPConnectionCallback

this is called when bytes are available to be sent to the client. you have to callback AMQPConnectionContext.outputDone(int) after you're done with this buffer

Specified by:

onTransport in interface AMQPConnectionCallback

createSessionCallback

public AMQPSessionCallback createSessionCallback(AMQPConnectionContext connection)

Specified by:

createSessionCallback in interface AMQPConnectionCallback