Uses of Class
org.apache.activemq.artemis.protocol.amqp.proton.AMQPSessionContext
Packages that use AMQPSessionContext
Package
Description
This package includes classes used to interact with the broker.
This contains a very limited ClientProtocolmanager for AMQP / Proton
Where it only satisfies very basic functionality.
This package includes classes used on the interaction with Proton, including Context classes that will be translated
through the model event.
-
Uses of AMQPSessionContext in org.apache.activemq.artemis.protocol.amqp.broker
Methods in org.apache.activemq.artemis.protocol.amqp.broker that return AMQPSessionContextMethods in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type AMQPSessionContextModifier and TypeMethodDescriptionvoidAMQPSessionCallback.init(AMQPSessionContext protonSession, SASLResult saslResult) -
Uses of AMQPSessionContext in org.apache.activemq.artemis.protocol.amqp.client
Constructors in org.apache.activemq.artemis.protocol.amqp.client with parameters of type AMQPSessionContextModifierConstructorDescriptionProtonClientSenderContext(AMQPConnectionContext connection, org.apache.qpid.proton.engine.Sender sender, AMQPSessionContext amqpSessionContext, AMQPSessionCallback sessionSPI) -
Uses of AMQPSessionContext in org.apache.activemq.artemis.protocol.amqp.connect.bridge
Fields in org.apache.activemq.artemis.protocol.amqp.connect.bridge declared as AMQPSessionContextModifier and TypeFieldDescriptionprotected AMQPSessionContextAMQPBridgePolicyManager.sessionprotected final AMQPSessionContextAMQPBridgeReceiver.sessionprotected final AMQPSessionContextAMQPBridgeSender.sessionprotected final AMQPSessionContextAMQPBridgeToSenderController.sessionMethods in org.apache.activemq.artemis.protocol.amqp.connect.bridge that return AMQPSessionContextModifier and TypeMethodDescriptionfinal AMQPSessionContextAMQPBridgeToSenderController.getSessionContext()Methods in org.apache.activemq.artemis.protocol.amqp.connect.bridge with parameters of type AMQPSessionContextModifier and TypeMethodDescriptionvoidAMQPBridgeManager.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.voidAMQPBridgeManagers.connectionRestored(AMQPSessionContext session) Signal all bridge managers that the connection has been restoredfinal voidAMQPBridgePolicyManager.connectionRestored(AMQPSessionContext session, AMQPBridgeConfiguration configuration) Called by the parent AMQP bridge manager when the connection has been established and this AMQP policy manager should build up its active state based on the configuration.Constructors in org.apache.activemq.artemis.protocol.amqp.connect.bridge with parameters of type AMQPSessionContextModifierConstructorDescriptionAMQPBridgeFromAddressReceiver(AMQPBridgeFromPolicyManager policyManager, AMQPBridgeReceiverConfiguration configuration, AMQPSessionContext session, AMQPBridgeReceiverInfo receiverInfo, AMQPBridgeAddressPolicy policy, AMQPBridgeMetrics.ReceiverMetrics metrics) AMQPBridgeFromQueueReceiver(AMQPBridgeFromPolicyManager policyManager, AMQPBridgeReceiverConfiguration configuration, AMQPSessionContext session, AMQPBridgeReceiverInfo receiverInfo, AMQPBridgeQueuePolicy policy, AMQPBridgeMetrics.ReceiverMetrics metrics) AMQPBridgeReceiver(AMQPBridgeFromPolicyManager policyManager, AMQPBridgeReceiverConfiguration configuration, AMQPSessionContext session, AMQPBridgeReceiverInfo receiverInfo, AMQPBridgePolicy policy, AMQPBridgeMetrics.ReceiverMetrics metrics) AMQPBridgeSender(AMQPBridgeToPolicyManager policyManager, AMQPBridgeSenderConfiguration configuration, AMQPSessionContext session, AMQPBridgeSenderInfo senderInfo, AMQPBridgeMetrics.SenderMetrics metrics) AMQPBridgeToAddressSender(AMQPBridgeToPolicyManager policyManager, AMQPBridgeSenderConfiguration configuration, AMQPSessionContext session, AMQPBridgeSenderInfo senderInfo, AMQPBridgeMetrics.SenderMetrics metrics) AMQPBridgeToAddressSenderController(AMQPBridgeSenderInfo senderInfo, AMQPBridgeSenderConfiguration configuration, AMQPBridgeToPolicyManager policyManager, AMQPSessionContext session, AMQPBridgeMetrics.SenderMetrics metrics) AMQPBridgeToQueueSender(AMQPBridgeToPolicyManager policyManager, AMQPBridgeSenderConfiguration configuration, AMQPSessionContext session, AMQPBridgeSenderInfo senderInfo, AMQPBridgeMetrics.SenderMetrics metrics) AMQPBridgeToQueueSenderController(AMQPBridgeSenderInfo senderInfo, AMQPBridgeSenderConfiguration configuration, AMQPBridgeToPolicyManager policyManager, AMQPSessionContext session, AMQPBridgeMetrics.SenderMetrics metrics) AMQPBridgeToSenderController(AMQPBridgeSenderInfo senderInfo, AMQPBridgeSenderConfiguration configuration, AMQPBridgeToPolicyManager policyManager, AMQPSessionContext session, AMQPBridgeMetrics.SenderMetrics metrics) -
Uses of AMQPSessionContext in org.apache.activemq.artemis.protocol.amqp.connect.federation
Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation declared as AMQPSessionContextModifier and TypeFieldDescriptionprotected AMQPSessionContextAMQPFederation.sessionprotected final AMQPSessionContextAMQPFederationConsumer.sessionprotected AMQPSessionContextAMQPFederationPolicyManager.sessionprotected final AMQPSessionContextAMQPFederationSenderController.sessionMethods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return AMQPSessionContextModifier and TypeMethodDescriptionabstract AMQPSessionContextAMQPFederation.getSessionContext()Returns the session context assigned to this federation instance.final AMQPSessionContextAMQPFederationSenderController.getSessionContext()AMQPFederationSource.getSessionContext()AMQPFederationTarget.getSessionContext()Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPSessionContextModifier and TypeMethodDescriptionfinal voidAMQPFederationSource.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 voidAMQPFederationAddressPolicyManager.updateStateAfterConnect(AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session) protected abstract voidAMQPFederationLocalPolicyManager.updateStateAfterConnect(AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session) Allows the policy manager implementation to update internal state after (re)connection and before the policy manager triggers a scan of all bindings to check for existing or new demand.protected voidAMQPFederationQueuePolicyManager.updateStateAfterConnect(AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session) Constructors in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPSessionContextModifierConstructorDescriptionAMQPFederationAddressBindingsConsumer(AMQPFederationAddressPolicyManager manager, AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session, FederationConsumerInfo consumerInfo, AMQPFederationMetrics.ConsumerMetrics metrics) AMQPFederationAddressConduitConsumer(AMQPFederationAddressPolicyManager manager, AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session, FederationConsumerInfo consumerInfo, AMQPFederationMetrics.ConsumerMetrics metrics) AMQPFederationAddressConsumer(AMQPFederationAddressPolicyManager manager, AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session, FederationConsumerInfo consumerInfo, AMQPFederationMetrics.ConsumerMetrics metrics) AMQPFederationCommandProcessor(AMQPFederationTarget federation, AMQPSessionContext session, org.apache.qpid.proton.engine.Receiver receiver) Create the new federation command receiverAMQPFederationConsumer(AMQPFederationLocalPolicyManager manager, AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session, FederationConsumerInfo consumerInfo, FederationReceiveFromResourcePolicy policy, AMQPFederationMetrics.ConsumerMetrics metrics) AMQPFederationEventProcessor(AMQPFederation federation, AMQPSessionContext session, org.apache.qpid.proton.engine.Receiver receiver) Create the new federation event receiverAMQPFederationQueueConsumer(AMQPFederationQueuePolicyManager manager, AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session, FederationConsumerInfo consumerInfo, AMQPFederationMetrics.ConsumerMetrics metrics) AMQPFederationTarget(AMQPRemoteBrokerConnection brokerConnection, String name, AMQPFederationConfiguration configuration, AMQPFederationCapabilities capabilities, AMQPSessionContext session) -
Uses of AMQPSessionContext in org.apache.activemq.artemis.protocol.amqp.connect.mirror
Constructors in org.apache.activemq.artemis.protocol.amqp.connect.mirror with parameters of type AMQPSessionContextModifierConstructorDescriptionAMQPMirrorControllerTarget(AMQPSessionCallback sessionSPI, AMQPConnectionContext connection, AMQPSessionContext protonSession, org.apache.qpid.proton.engine.Receiver receiver, org.apache.activemq.artemis.core.server.ActiveMQServer server) -
Uses of AMQPSessionContext in org.apache.activemq.artemis.protocol.amqp.proton
Fields in org.apache.activemq.artemis.protocol.amqp.proton declared as AMQPSessionContextModifier and TypeFieldDescriptionprotected final AMQPSessionContextProtonAbstractReceiver.protonSessionprotected final AMQPSessionContextProtonServerSenderContext.protonSessionMethods in org.apache.activemq.artemis.protocol.amqp.proton that return AMQPSessionContextModifier and TypeMethodDescriptionProtonAbstractReceiver.getSessionContext()ProtonServerSenderContext.getSessionContext()AMQPConnectionContext.getSessionExtension(org.apache.qpid.proton.engine.Session realSession) protected AMQPSessionContextAMQPConnectionContext.newSessionExtension(org.apache.qpid.proton.engine.Session realSession) Methods in org.apache.activemq.artemis.protocol.amqp.proton that return types with arguments of type AMQPSessionContextModifier and TypeMethodDescriptionMap<org.apache.qpid.proton.engine.Session, AMQPSessionContext> AMQPConnectionContext.getSessions()Method parameters in org.apache.activemq.artemis.protocol.amqp.proton with type arguments of type AMQPSessionContextModifier and TypeMethodDescription<T extends ProtonAbstractReceiver>
TAMQPSessionContext.addReceiver(org.apache.qpid.proton.engine.Receiver receiver, BiFunction<AMQPSessionContext, org.apache.qpid.proton.engine.Receiver, T> receiverBuilder) <T extends ProtonServerSenderContext>
TAMQPSessionContext.addSender(org.apache.qpid.proton.engine.Sender sender, BiFunction<AMQPSessionContext, org.apache.qpid.proton.engine.Sender, T> senderBuilder) Constructors in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type AMQPSessionContextModifierConstructorDescriptionDefaultSenderController(AMQPSessionContext session, org.apache.qpid.proton.engine.Sender protonSender, String clientId) 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)