Uses of Interface
org.apache.activemq.artemis.core.client.impl.ClientConsumerInternal

Packages that use ClientConsumerInternal

Package	Description
org.apache.activemq.artemis.core.client.impl
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.protocol.hornetq.client
org.apache.activemq.artemis.spi.core.remoting

Uses of ClientConsumerInternal in org.apache.activemq.artemis.core.client.impl

Classes in org.apache.activemq.artemis.core.client.impl that implement ClientConsumerInternal

Modifier and Type	Class	Description
final class	ClientConsumerImpl

Methods in org.apache.activemq.artemis.core.client.impl that return types with arguments of type ClientConsumerInternal

Modifier and Type	Method	Description
Map<ConsumerContext,ClientConsumerInternal>	ClientSessionImpl.cloneConsumerEntries()
Set<ClientConsumerInternal>	ClientSessionImpl.cloneConsumers()	Not part of the interface, used on tests only

Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ClientConsumerInternal

Modifier and Type	Method	Description
void	ClientSessionImpl.addConsumer(ClientConsumerInternal consumer)
void	ClientSessionInternal.addConsumer(ClientConsumerInternal consumer)
void	ClientMessageImpl.onReceipt(ClientConsumerInternal consumer)
void	ClientMessageInternal.onReceipt(ClientConsumerInternal consumer)
void	ClientSessionImpl.removeConsumer(ClientConsumerInternal consumer)
void	ClientSessionInternal.removeConsumer(ClientConsumerInternal consumer)

Constructors in org.apache.activemq.artemis.core.client.impl with parameters of type ClientConsumerInternal

Modifier	Constructor	Description
	LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout)
	LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout, File cachedFile)
	LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout, File cachedFile, int bufferSize)

Uses of ClientConsumerInternal in org.apache.activemq.artemis.core.protocol.core.impl

Methods in org.apache.activemq.artemis.core.protocol.core.impl that return ClientConsumerInternal

Modifier and Type	Method	Description
ClientConsumerInternal	ActiveMQSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout)

Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type ClientConsumerInternal

Modifier and Type	Method	Description
void	ActiveMQSessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal, long consumerId, boolean isSessionStarted)

Uses of ClientConsumerInternal in org.apache.activemq.artemis.core.protocol.hornetq.client

Methods in org.apache.activemq.artemis.core.protocol.hornetq.client that return ClientConsumerInternal

Modifier and Type	Method	Description
ClientConsumerInternal	HornetQClientSessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout)

Uses of ClientConsumerInternal in org.apache.activemq.artemis.spi.core.remoting

Methods in org.apache.activemq.artemis.spi.core.remoting that return ClientConsumerInternal

Modifier and Type	Method	Description
abstract ClientConsumerInternal	SessionContext.createConsumer(SimpleString queueName, SimpleString filterString, int priority, int windowSize, int maxRate, int ackBatchSize, boolean browseOnly, Executor executor, Executor flowControlExecutor, int onMessageCloseTimeout)

Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ClientConsumerInternal

Modifier and Type	Method	Description
abstract void	SessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal, long consumerId, boolean isSessionStarted)