Uses of Class
org.apache.activemq.artemis.protocol.amqp.broker.ProtonProtocolManager
Packages that use ProtonProtocolManager
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 ProtonProtocolManager in org.apache.activemq.artemis.protocol.amqp.broker
Methods in org.apache.activemq.artemis.protocol.amqp.broker that return ProtonProtocolManagerModifier and TypeMethodDescriptionActiveMQProtonRemotingConnection.getManager()AMQPSessionCallback.getProtocolManager()ProtonProtocolManager.setAckManagerFlushTimeout(long ackManagerFlushTimeout) ProtonProtocolManager.setAmqpCredits(int amqpCredits) ProtonProtocolManager.setAmqpDrainOnTransientDeliveryErrors(boolean amqpDrainOnTransientDeliveryErrors) Sets if transient delivery errors should be handled by draining link credit from the remote senderProtonProtocolManager.setAmqpDuplicateDetection(boolean duplicateDetection) ProtonProtocolManager.setAmqpIdleTimeout(Long ttl) ProtonProtocolManager.setAmqpLinkQuiesceTimeout(int amqpLinkQuiesceTimeout) Sets the time in milliseconds to wait before closing a remote sender link if the server has requested that the link drain all outstanding credit an complete pending settlements.ProtonProtocolManager.setAmqpLowCredits(int amqpLowCredits) ProtonProtocolManager.setAmqpMinLargeMessageSize(int amqpMinLargeMessageSize) ProtonProtocolManager.setAmqpUseModifiedForTransientDeliveryErrors(boolean amqpUseModifiedForTransientDeliveryErrors) Sets if transient delivery errors should be handled with a Modified disposition (if permitted by link)ProtonProtocolManager.setDirectDeliver(boolean directDeliver) ProtonProtocolManager.setMirrorMaxPendingAcks(int maxPendingAcks) Constructors in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type ProtonProtocolManagerModifierConstructorDescriptionActiveMQProtonRemotingConnection(ProtonProtocolManager manager, AMQPConnectionContext amqpConnection, Connection transportConnection, Executor connectionExecutor) AMQPConnectionCallback(ProtonProtocolManager manager, Connection connection, Executor sessionExecutor, org.apache.activemq.artemis.core.server.ActiveMQServer server) AMQPSessionCallback(AMQPConnectionCallback protonSPI, ProtonProtocolManager manager, AMQPConnectionContext connection, Connection transportConnection, Executor executor, org.apache.activemq.artemis.core.persistence.OperationContext operationContext) -
Uses of ProtonProtocolManager in org.apache.activemq.artemis.protocol.amqp.client
Subclasses of ProtonProtocolManager in org.apache.activemq.artemis.protocol.amqp.clientModifier and TypeClassDescriptionclassHandles proton protocol management for clients, mapping theProtonProtocolManagerto theClientProtocolManagerAPI.Classes in org.apache.activemq.artemis.protocol.amqp.client that implement interfaces with type arguments of type ProtonProtocolManagerModifier and TypeClassDescriptionclassManages the lifecycle of a proton client connection.Methods in org.apache.activemq.artemis.protocol.amqp.client with parameters of type ProtonProtocolManagerModifier and TypeMethodDescriptionvoidProtonClientConnectionManager.connectionCreated(org.apache.activemq.artemis.core.server.ActiveMQComponent component, Connection connection, ProtonProtocolManager protocolManager) AMQPClientConnectionFactory.createConnection(ProtonProtocolManager protocolManager, Connection connection, Optional<EventHandler> eventHandler, ClientSASLFactory clientSASLFactory) -
Uses of ProtonProtocolManager in org.apache.activemq.artemis.protocol.amqp.connect
Fields in org.apache.activemq.artemis.protocol.amqp.connect declared as ProtonProtocolManagerModifier and TypeFieldDescriptionfinal ProtonProtocolManagerAMQPBrokerConnectionManager.ClientProtocolManagerWithAMQP.protonPMMethods in org.apache.activemq.artemis.protocol.amqp.connect that return ProtonProtocolManagerModifier and TypeMethodDescriptionAMQPBrokerConnectionManager.ClientProtocolManagerWithAMQP.getProtonPM()Constructors in org.apache.activemq.artemis.protocol.amqp.connect with parameters of type ProtonProtocolManager -
Uses of ProtonProtocolManager in org.apache.activemq.artemis.protocol.amqp.proton
Methods in org.apache.activemq.artemis.protocol.amqp.proton that return ProtonProtocolManagerConstructors in org.apache.activemq.artemis.protocol.amqp.proton with parameters of type ProtonProtocolManagerModifierConstructorDescriptionAMQPConnectionContext(ProtonProtocolManager protocolManager, AMQPConnectionCallback connectionSP, String containerId, int idleTimeout, int maxFrameSize, int channelMax, boolean useCoreSubscriptionNaming, ScheduledExecutorService scheduledPool, boolean isIncomingConnection, ClientSASLFactory saslClientFactory, Map<org.apache.qpid.proton.amqp.Symbol, Object> connectionProperties, org.apache.qpid.proton.amqp.Symbol[] offeredCapabilities, org.apache.qpid.proton.amqp.Symbol[] desiredCapabilities) AMQPConnectionContext(ProtonProtocolManager protocolManager, AMQPConnectionCallback connectionSP, String containerId, int idleTimeout, int maxFrameSize, int channelMax, boolean useCoreSubscriptionNaming, ScheduledExecutorService scheduledPool, boolean isIncomingConnection, ClientSASLFactory saslClientFactory, Map<org.apache.qpid.proton.amqp.Symbol, Object> connectionProperties, org.apache.qpid.proton.amqp.Symbol[] offeredCapabilities, org.apache.qpid.proton.amqp.Symbol[] desiredCapabilities, boolean brokerConnection)