Uses of Class
org.apache.activemq.artemis.spi.core.remoting.ConsumerContext
Packages that use ConsumerContext
Package
Description
-
Uses of ConsumerContext in org.apache.activemq.artemis.api.core.client
Methods in org.apache.activemq.artemis.api.core.client that return ConsumerContextModifier and TypeMethodDescriptionClientConsumer.getConsumerContext()The server's ID associated with this consumer. -
Uses of ConsumerContext in org.apache.activemq.artemis.core.client.impl
Methods in org.apache.activemq.artemis.core.client.impl that return ConsumerContextMethods in org.apache.activemq.artemis.core.client.impl that return types with arguments of type ConsumerContextMethods in org.apache.activemq.artemis.core.client.impl with parameters of type ConsumerContextModifier and TypeMethodDescriptionvoidClientSessionImpl.handleConsumerDisconnect(ConsumerContext context) voidClientSessionInternal.handleConsumerDisconnect(ConsumerContext consumerContext) voidClientSessionImpl.handleReceiveContinuation(ConsumerContext consumerID, byte[] chunk, int flowControlSize, boolean isContinues) voidClientSessionInternal.handleReceiveContinuation(ConsumerContext consumerID, byte[] chunk, int flowControlSize, boolean isContinues) voidClientSessionImpl.handleReceiveLargeMessage(ConsumerContext consumerID, ClientLargeMessageInternal clientLargeMessage, long largeMessageSize) voidClientSessionInternal.handleReceiveLargeMessage(ConsumerContext consumerID, ClientLargeMessageInternal clientLargeMessage, long largeMessageSize) voidClientSessionImpl.handleReceiveMessage(ConsumerContext consumerID, ClientMessageInternal message) voidClientSessionInternal.handleReceiveMessage(ConsumerContext consumerID, ClientMessageInternal message) Constructors in org.apache.activemq.artemis.core.client.impl with parameters of type ConsumerContextModifierConstructorDescriptionClientConsumerImpl(ClientSessionInternal session, ConsumerContext consumerContext, SimpleString queueName, SimpleString filterString, int priority, boolean browseOnly, int initialWindow, int clientWindowSize, int ackBatchSize, TokenBucketLimiter rateLimiter, Executor executor, Executor flowControlExecutor, SessionContext sessionContext, ClientSession.QueueQuery queueInfo, ClassLoader contextClassLoader, int onMessageCloseTimeout) -
Uses of ConsumerContext in org.apache.activemq.artemis.core.protocol.core.impl
Subclasses of ConsumerContext in org.apache.activemq.artemis.core.protocol.core.impl -
Uses of ConsumerContext in org.apache.activemq.artemis.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ConsumerContextModifier and TypeMethodDescriptionprotected voidSessionContext.handleReceiveContinuation(ConsumerContext consumerID, byte[] chunk, int flowControlSize, boolean isContinues) protected voidSessionContext.handleReceiveLargeMessage(ConsumerContext consumerID, ClientLargeMessageInternal clientLargeMessage, long largeMessageSize) protected voidSessionContext.handleReceiveMessage(ConsumerContext consumerID, ClientMessageInternal message)