Uses of Class
org.apache.activemq.artemis.spi.core.remoting.ConsumerContext
-
-
Uses of ConsumerContext in org.apache.activemq.artemis.api.core.client
Methods in org.apache.activemq.artemis.api.core.client that return ConsumerContext Modifier and Type Method Description ConsumerContextClientConsumer. 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 ConsumerContext Modifier and Type Method Description ConsumerContextClientConsumerImpl. getConsumerContext()Methods in org.apache.activemq.artemis.core.client.impl that return types with arguments of type ConsumerContext Modifier and Type Method Description Map<ConsumerContext,ClientConsumerInternal>ClientSessionImpl. cloneConsumerEntries()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ConsumerContext Modifier and Type Method Description voidClientSessionImpl. 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 ConsumerContext Constructor Description ClientConsumerImpl(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) -
Uses of ConsumerContext in org.apache.activemq.artemis.core.protocol.core.impl
Subclasses of ConsumerContext in org.apache.activemq.artemis.core.protocol.core.impl Modifier and Type Class Description classActiveMQConsumerContext -
Uses of ConsumerContext in org.apache.activemq.artemis.spi.core.remoting
Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ConsumerContext Modifier and Type Method Description protected 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)
-