org.apache.activemq.artemis.protocol.amqp.broker

Class AMQPConnectionCallback

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.broker.AMQPConnectionCallback

All Implemented Interfaces:

CloseListener, FailureListener

public class AMQPConnectionCallback
extends Object
implements FailureListener, CloseListener

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AMQPConnectionCallback(ProtonProtocolManager manager, Connection connection, Executor closeExecutor, ActiveMQServer server)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connectionClosed()
void	connectionFailed(ActiveMQException exception, boolean failedOver)
void	connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)
AMQPSessionCallback	createSessionCallback(AMQPConnectionContext connection)
AMQPConnectionContext	getConnection()
Executor	getExeuctor()
ActiveMQProtonRemotingConnection	getProtonConnectionDelegate()
ServerSASL[]	getSASLMechnisms()
Transaction	getTransaction(org.apache.qpid.proton.amqp.Binary txid)
boolean	isSupportsAnonymous()
org.apache.qpid.proton.amqp.Binary	newTransaction()
protected XidImpl	newXID()
protected XidImpl	newXID(byte[] bytes)
void	onTransport(io.netty.buffer.ByteBuf byteBuf, AMQPConnectionContext amqpConnection)
void	removeTransaction(org.apache.qpid.proton.amqp.Binary txid)
void	sendSASLSupported()
void	setConnection(AMQPConnectionContext connection)
void	setProtonConnectionDelegate(ActiveMQProtonRemotingConnection protonConnectionDelegate)
boolean	validateConnection(org.apache.qpid.proton.engine.Connection connection, SASLResult saslResult)

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

AMQPConnectionCallback

public AMQPConnectionCallback(ProtonProtocolManager manager,
                              Connection connection,
                              Executor closeExecutor,
                              ActiveMQServer server)

Method Detail

getSASLMechnisms

public ServerSASL[] getSASLMechnisms()

isSupportsAnonymous

public boolean isSupportsAnonymous()

close

public void close()

getExeuctor

public Executor getExeuctor()

setConnection

public void setConnection(AMQPConnectionContext connection)

getConnection

public AMQPConnectionContext getConnection()

getProtonConnectionDelegate

public ActiveMQProtonRemotingConnection getProtonConnectionDelegate()

setProtonConnectionDelegate

public void setProtonConnectionDelegate(ActiveMQProtonRemotingConnection protonConnectionDelegate)

onTransport

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

createSessionCallback

public AMQPSessionCallback createSessionCallback(AMQPConnectionContext connection)

sendSASLSupported

public void sendSASLSupported()

validateConnection

public boolean validateConnection(org.apache.qpid.proton.engine.Connection connection,
                                  SASLResult saslResult)

connectionClosed

public void connectionClosed()

Specified by:

connectionClosed in interface CloseListener

connectionFailed

public void connectionFailed(ActiveMQException exception,
                             boolean failedOver)

Specified by:

connectionFailed in interface FailureListener

connectionFailed

public void connectionFailed(ActiveMQException exception,
                             boolean failedOver,
                             String scaleDownTargetNodeID)

Specified by:

connectionFailed in interface FailureListener

newTransaction

public org.apache.qpid.proton.amqp.Binary newTransaction()

getTransaction

public Transaction getTransaction(org.apache.qpid.proton.amqp.Binary txid)
                           throws ActiveMQAMQPException

Throws:

ActiveMQAMQPException

removeTransaction

public void removeTransaction(org.apache.qpid.proton.amqp.Binary txid)

newXID

protected XidImpl newXID()

newXID

protected XidImpl newXID(byte[] bytes)