Uses of Class
org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext

Packages that use AMQPConnectionContext

Package	Description
org.apache.activemq.artemis.protocol.amqp.broker	This package includes classes used to interact with the broker.
org.apache.activemq.artemis.protocol.amqp.client	This contains a very limited ClientProtocolmanager for AMQP / Proton Where it only satisfies very basic functionality.
org.apache.activemq.artemis.protocol.amqp.connect
org.apache.activemq.artemis.protocol.amqp.connect.bridge
org.apache.activemq.artemis.protocol.amqp.connect.federation
org.apache.activemq.artemis.protocol.amqp.connect.mirror
org.apache.activemq.artemis.protocol.amqp.proton	This package includes classes used on the interaction with Proton, including Context classes that will be translated through the model event.
org.apache.activemq.artemis.protocol.amqp.proton.handler
org.apache.activemq.artemis.protocol.amqp.proton.transaction

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.broker

Fields in org.apache.activemq.artemis.protocol.amqp.broker declared as AMQPConnectionContext

Modifier and Type	Field	Description
protected AMQPConnectionContext	AMQPConnectionCallback.amqpConnection

Methods in org.apache.activemq.artemis.protocol.amqp.broker that return AMQPConnectionContext

Modifier and Type	Method	Description
AMQPConnectionContext	ActiveMQProtonRemotingConnection.getAmqpConnection()
AMQPConnectionContext	AMQPConnectionCallback.getConnection()

Methods in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type AMQPConnectionContext

Modifier and Type	Method	Description
AMQPSessionCallback	AMQPConnectionCallback.createSessionCallback(AMQPConnectionContext connection)
void	AMQPConnectionCallback.onTransport(io.netty.buffer.ByteBuf byteBuf, AMQPConnectionContext amqpConnection)
void	AMQPConnectionCallback.setConnection(AMQPConnectionContext connection)

Constructors in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	ActiveMQProtonRemotingConnection(ProtonProtocolManager manager, AMQPConnectionContext amqpConnection, Connection transportConnection, Executor connectionExecutor)
	AMQPSessionCallback(AMQPConnectionCallback protonSPI, ProtonProtocolManager manager, AMQPConnectionContext connection, Connection transportConnection, Executor executor, org.apache.activemq.artemis.core.persistence.OperationContext operationContext)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.client

Constructors in org.apache.activemq.artemis.protocol.amqp.client with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	ProtonClientSenderContext(AMQPConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AMQPSessionContext amqpSessionContext, AMQPSessionCallback sessionSPI)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.connect

Methods in org.apache.activemq.artemis.protocol.amqp.connect that return AMQPConnectionContext

Modifier and Type	Method	Description
AMQPConnectionContext	AMQPRemoteBrokerConnection.getConnection()	Returns the connection context for this incoming broker connection.

Methods in org.apache.activemq.artemis.protocol.amqp.connect with parameters of type AMQPConnectionContext

Modifier and Type	Method	Description
static AMQPRemoteBrokerConnection	AMQPRemoteBrokerConnection.getOrCreateRemoteBrokerConnection(org.apache.activemq.artemis.core.server.ActiveMQServer server, AMQPConnectionContext connection, org.apache.qpid.proton.engine.Connection protonConnection)	Utility methods for checking the current connection for an existing remote broker connection instance and returning it, or creating a new instance if none yet exists and initializing it.

Constructors in org.apache.activemq.artemis.protocol.amqp.connect with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	AMQPRemoteBrokerConnection(org.apache.activemq.artemis.core.server.ActiveMQServer server, AMQPConnectionContext connection, String remoteNodeId, String remoteConnectionName)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.connect.bridge

Fields in org.apache.activemq.artemis.protocol.amqp.connect.bridge declared as AMQPConnectionContext

Modifier and Type	Field	Description
protected final AMQPConnectionContext	AMQPBridgeReceiver.connection
protected final AMQPConnectionContext	AMQPBridgeSender.connection

Methods in org.apache.activemq.artemis.protocol.amqp.connect.bridge with parameters of type AMQPConnectionContext

Modifier and Type	Method	Description
void	AMQPBridgeManager.connectionRestored(AMQPConnectionContext connection, AMQPSessionContext session)	Called by the parent broker connection when the connection has been established and this AMQP bridge should build up its active state based on the configuration.

Constructors in org.apache.activemq.artemis.protocol.amqp.connect.bridge with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	AMQPBridgeConfiguration(AMQPConnectionContext connection, Map<String,Object> properties)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.connect.federation

Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation declared as AMQPConnectionContext

Modifier and Type	Field	Description
protected AMQPConnectionContext	AMQPFederation.connection
protected final AMQPConnectionContext	AMQPFederationConsumer.connection

Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return AMQPConnectionContext

Modifier and Type	Method	Description
abstract AMQPConnectionContext	AMQPFederation.getConnectionContext()	Returns the session context assigned to this federation instance.
AMQPConnectionContext	AMQPFederationSource.getConnectionContext()
AMQPConnectionContext	AMQPFederationTarget.getConnectionContext()

Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPConnectionContext

Modifier and Type	Method	Description
final void	AMQPFederationSource.connectionRestored(AMQPConnectionContext connection, AMQPSessionContext session)	Called by the parent broker connection when the connection has been established and this federation should build up its active state based on the configuration.
protected final Runnable	AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler.createCreditRunnable(AMQPConnectionContext connection)
protected Runnable	AMQPFederationCommandProcessor.createCreditRunnable(AMQPConnectionContext connection)
protected Runnable	AMQPFederationEventProcessor.createCreditRunnable(AMQPConnectionContext connection)
protected final int	AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler.getConfiguredMinLargeMessageSize(AMQPConnectionContext connection)
protected int	AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler.getLinkQuiesceTimeout(AMQPConnectionContext connection)
protected boolean	AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler.isDrainOnTransientDeliveryErrors(AMQPConnectionContext connection)
protected boolean	AMQPFederationAddressConsumer.AMQPFederatedAddressDeliveryHandler.isUseModifiedForTransientDeliveryErrors(AMQPConnectionContext connection)

Constructors in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	AMQPFederationConfiguration(AMQPConnectionContext connection, Map<String,Object> properties)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.connect.mirror

Constructors in org.apache.activemq.artemis.protocol.amqp.connect.mirror with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	AMQPMirrorControllerTarget(AMQPSessionCallback sessionSPI, AMQPConnectionContext connection, AMQPSessionContext protonSession, org.apache.qpid.proton.engine.Receiver receiver, org.apache.activemq.artemis.core.server.ActiveMQServer server)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.proton

Fields in org.apache.activemq.artemis.protocol.amqp.proton declared as AMQPConnectionContext

Modifier and Type	Field	Description
protected final AMQPConnectionContext	AMQPSessionContext.connection
protected final AMQPConnectionContext	ProtonAbstractReceiver.connection
protected final AMQPConnectionContext	ProtonServerSenderContext.connection

Methods in org.apache.activemq.artemis.protocol.amqp.proton that return AMQPConnectionContext

Modifier and Type	Method	Description
AMQPConnectionContext	AMQPConnectionContext.addLinkRemoteCloseListener(String id, LinkCloseListener linkCloseListener)	Adds a listener that will be invoked any time an AMQP link is remotely closed before having been closed on this end of the connection.
AMQPConnectionContext	AMQPConnectionContext.addRemoteOpenedListener(Consumer<AMQPConnectionContext> listener)
AMQPConnectionContext	AMQPSessionContext.getAMQPConnectionContext()
AMQPConnectionContext	ProtonAbstractReceiver.getConnection()

Methods in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type AMQPConnectionContext

Modifier and Type	Method	Description
static Runnable	ProtonAbstractReceiver.createCreditRunnable(int refill, int threshold, org.apache.qpid.proton.engine.Receiver receiver, AMQPConnectionContext connection, ProtonAbstractReceiver context)	This Credit Runnable can be used to manage the credit replenishment of a target AMQP receiver.
protected Runnable	ProtonAbstractReceiver.createCreditRunnable(AMQPConnectionContext connection)	Subclass can override this to provide a custom credit runnable that performs other checks or applies credit in a manner more fitting that implementation.
protected int	ProtonAbstractReceiver.getConfiguredMinLargeMessageSize(AMQPConnectionContext connection)	Subclass can override this to provide the minimum large message size that should be used when creating receiver instances.
protected int	ProtonAbstractReceiver.getLinkQuiesceTimeout(AMQPConnectionContext connection)	Gets the time in milliseconds that the receiver should wait before it considers a link quiesce attempt to have failed and act to close the link with an error, this allows subclass implementations to override the defaults set on the connection level.
protected boolean	ProtonAbstractReceiver.isDrainOnTransientDeliveryErrors(AMQPConnectionContext connection)	Should the receiver drain link credit when a transient delivery error occurs, this allows subclass implementations to override the defaults set on the connection level.
protected boolean	ProtonAbstractReceiver.isUseModifiedForTransientDeliveryErrors(AMQPConnectionContext connection)	Should the receiver send an AMQP Modified disposition with delivery failed set to true for address full errors instead of the Rejected disposition it would by default.
boolean	AMQPRoutingHandler.route(AMQPConnectionContext connectionContext, org.apache.qpid.proton.engine.Connection protonConnection)

Method parameters in org.apache.activemq.artemis.protocol.amqp.proton with type arguments of type AMQPConnectionContext

Modifier and Type	Method	Description
AMQPConnectionContext	AMQPConnectionContext.addRemoteOpenedListener(Consumer<AMQPConnectionContext> listener)

Constructors in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	AMQPRoutingContext(AMQPConnectionContext connectionContext, org.apache.qpid.proton.engine.Connection protonConnection)
	AMQPSessionContext(AMQPSessionCallback sessionSPI, AMQPConnectionContext connection, org.apache.qpid.proton.engine.Session session, org.apache.activemq.artemis.core.server.ActiveMQServer server)
	ProtonAbstractReceiver(AMQPSessionCallback sessionSPI, AMQPConnectionContext connection, AMQPSessionContext protonSession, org.apache.qpid.proton.engine.Receiver receiver)
	ProtonServerReceiverContext(AMQPSessionCallback sessionSPI, AMQPConnectionContext connection, AMQPSessionContext protonSession, org.apache.qpid.proton.engine.Receiver receiver)
	ProtonServerSenderContext(AMQPConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AMQPSessionContext protonSession, AMQPSessionCallback server)
	ProtonServerSenderContext(AMQPConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AMQPSessionContext protonSession, AMQPSessionCallback server, SenderController senderController)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.proton.handler

Methods in org.apache.activemq.artemis.protocol.amqp.proton.handler with parameters of type AMQPConnectionContext

Modifier and Type	Method	Description
void	ProtonHandler.close(org.apache.qpid.proton.amqp.transport.ErrorCondition errorCondition, AMQPConnectionContext connectionContext)

Uses of AMQPConnectionContext in org.apache.activemq.artemis.protocol.amqp.proton.transaction

Constructors in org.apache.activemq.artemis.protocol.amqp.proton.transaction with parameters of type AMQPConnectionContext

Modifier	Constructor	Description
	ProtonTransactionHandler(AMQPSessionCallback sessionSPI, AMQPConnectionContext connection)
	ProtonTransactionImpl(Xid xid, org.apache.activemq.artemis.core.persistence.StorageManager storageManager, int timeoutSeconds, AMQPConnectionContext connection)