Uses of Class
org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerSenderContext
Packages that use ProtonServerSenderContext
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 ProtonServerSenderContext in org.apache.activemq.artemis.protocol.amqp.broker
Methods in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type ProtonServerSenderContextModifier and TypeMethodDescriptionorg.apache.activemq.artemis.core.server.ServerConsumerAMQPSessionCallback.createSender(ProtonServerSenderContext protonSender, SimpleString queue, String filter, boolean browserOnly) Creates a server consume that reads from the given named queue and forwards the read messages to the AMQP sender to dispatch to the remote peer.org.apache.activemq.artemis.core.server.ServerConsumerAMQPSessionCallback.createSender(ProtonServerSenderContext protonSender, SimpleString queue, String filter, boolean browserOnly, Number priority) Creates a server consume that reads from the given named queue and forwards the read messages to the AMQP sender to dispatch to the remote peer. -
Uses of ProtonServerSenderContext in org.apache.activemq.artemis.protocol.amqp.client
Modifier and TypeClassDescriptionclassTODO: MergeProtonServerSenderContextandProtonClientSenderContextonce we support 'global' link names. -
Uses of ProtonServerSenderContext in org.apache.activemq.artemis.protocol.amqp.connect.bridge
Fields in org.apache.activemq.artemis.protocol.amqp.connect.bridge declared as ProtonServerSenderContextModifier and TypeFieldDescriptionprotected ProtonServerSenderContextAMQPBridgeSender.senderContextprotected ProtonServerSenderContextAMQPBridgeToSenderController.senderContextMethods in org.apache.activemq.artemis.protocol.amqp.connect.bridge that return ProtonServerSenderContextMethods in org.apache.activemq.artemis.protocol.amqp.connect.bridge with parameters of type ProtonServerSenderContextModifier and TypeMethodDescriptionprotected org.apache.activemq.artemis.core.server.ServerConsumerAMQPBridgeToAddressSender.AMQPBridgeToAddressSenderController.createServerConsumer(ProtonServerSenderContext senderContext) protected org.apache.activemq.artemis.core.server.ServerConsumerAMQPBridgeToQueueSender.AMQPBridgeToQueueSenderController.createServerConsumer(ProtonServerSenderContext senderContext) protected abstract org.apache.activemq.artemis.core.server.ServerConsumerAMQPBridgeToSenderController.createServerConsumer(ProtonServerSenderContext senderContext) The subclass must implement this and create an appropriately configured server consumer based on the properties of the AMQP link and the role of the implemented sender type.final org.apache.activemq.artemis.core.server.ServerConsumerAMQPBridgeToSenderController.init(ProtonServerSenderContext senderContext) final MessageWriterAMQPBridgeToSenderController.selectOutgoingMessageWriter(ProtonServerSenderContext sender, org.apache.activemq.artemis.core.server.MessageReference reference) -
Uses of ProtonServerSenderContext in org.apache.activemq.artemis.protocol.amqp.connect.federation
Fields in org.apache.activemq.artemis.protocol.amqp.connect.federation declared as ProtonServerSenderContextModifier and TypeFieldDescriptionprotected ProtonServerSenderContextAMQPFederationSenderController.senderContextMethods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return ProtonServerSenderContextMethods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type ProtonServerSenderContextModifier and TypeMethodDescriptionorg.apache.activemq.artemis.core.server.ServerConsumerAMQPFederationAddressSenderController.createServerConsumer(ProtonServerSenderContext senderContext) org.apache.activemq.artemis.core.server.ServerConsumerAMQPFederationQueueSenderController.createServerConsumer(ProtonServerSenderContext senderContext) protected abstract org.apache.activemq.artemis.core.server.ServerConsumerAMQPFederationSenderController.createServerConsumer(ProtonServerSenderContext senderContext) The subclass must implement this and create an appropriately configured server consumer based on the properties of the AMQP link and the role of the implemented sender type.org.apache.activemq.artemis.core.server.ConsumerAMQPFederationCommandDispatcher.init(ProtonServerSenderContext senderContext) org.apache.activemq.artemis.core.server.ConsumerAMQPFederationEventDispatcher.init(ProtonServerSenderContext senderContext) final org.apache.activemq.artemis.core.server.ServerConsumerAMQPFederationSenderController.init(ProtonServerSenderContext senderContext) final MessageWriterAMQPFederationSenderController.selectOutgoingMessageWriter(ProtonServerSenderContext sender, org.apache.activemq.artemis.core.server.MessageReference reference) -
Uses of ProtonServerSenderContext in org.apache.activemq.artemis.protocol.amqp.proton
Fields in org.apache.activemq.artemis.protocol.amqp.proton with type parameters of type ProtonServerSenderContextModifier and TypeFieldDescriptionprotected Map<org.apache.qpid.proton.engine.Sender, ProtonServerSenderContext> AMQPSessionContext.sendersprotected Map<Object, ProtonServerSenderContext> AMQPSessionContext.serverSendersMethods in org.apache.activemq.artemis.protocol.amqp.proton with type parameters of type ProtonServerSenderContextModifier and TypeMethodDescription<T extends ProtonServerSenderContext>
TAMQPSessionContext.addSender(org.apache.qpid.proton.engine.Sender sender, BiFunction<AMQPSessionContext, org.apache.qpid.proton.engine.Sender, T> senderBuilder) Methods in org.apache.activemq.artemis.protocol.amqp.proton that return ProtonServerSenderContextModifier and TypeMethodDescriptionProtonServerSenderContext.setBeforeDelivery(Consumer<? super org.apache.activemq.artemis.core.server.MessageReference> beforeDelivery) Methods in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type ProtonServerSenderContextModifier and TypeMethodDescriptionvoidAMQPSessionContext.addSender(org.apache.qpid.proton.engine.Sender sender, ProtonServerSenderContext protonSender) org.apache.activemq.artemis.core.server.ConsumerDefaultSenderController.init(ProtonServerSenderContext senderContext) org.apache.activemq.artemis.core.server.ConsumerSenderController.init(ProtonServerSenderContext senderContext) Initialize sender controller state and handle open of AMQP sender resourcesDefaultSenderController.selectOutgoingMessageWriter(ProtonServerSenderContext sender, org.apache.activemq.artemis.core.server.MessageReference reference) default MessageWriterSenderController.selectOutgoingMessageWriter(ProtonServerSenderContext sender, org.apache.activemq.artemis.core.server.MessageReference reference) Controller selects a outgoing delivery writer that will handle the encoding and writing of the targetMessagecarried in the givenMessageReference.Constructors in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type ProtonServerSenderContextModifierConstructorDescriptionAMQPLargeMessageWriter(ProtonServerSenderContext serverSender) AMQPMessageWriter(ProtonServerSenderContext serverSender) AMQPTunneledCoreLargeMessageWriter(ProtonServerSenderContext serverSender) AMQPTunneledCoreMessageWriter(ProtonServerSenderContext serverSender) -
Uses of ProtonServerSenderContext in org.apache.activemq.artemis.protocol.amqp.proton.transaction
Methods in org.apache.activemq.artemis.protocol.amqp.proton.transaction that return types with arguments of type ProtonServerSenderContextModifier and TypeMethodDescriptionMap<org.apache.activemq.artemis.core.server.MessageReference, Pair<org.apache.qpid.proton.engine.Delivery, ProtonServerSenderContext>> ProtonTransactionImpl.getDeliveries()Methods in org.apache.activemq.artemis.protocol.amqp.proton.transaction with parameters of type ProtonServerSenderContextModifier and TypeMethodDescriptionvoidProtonTransactionImpl.addDelivery(org.apache.qpid.proton.engine.Delivery delivery, ProtonServerSenderContext context)