Uses of Interface
org.apache.activemq.artemis.core.client.impl.ClientConsumerInternal
Packages that use ClientConsumerInternal
Package
Description
-
Uses of ClientConsumerInternal in org.apache.activemq.artemis.core.client.impl
Classes in org.apache.activemq.artemis.core.client.impl that implement ClientConsumerInternalMethods in org.apache.activemq.artemis.core.client.impl that return types with arguments of type ClientConsumerInternalModifier and TypeMethodDescriptionClientSessionImpl.cloneConsumerEntries()ClientSessionImpl.cloneConsumers()Not part of the interface, used on tests onlyMethods in org.apache.activemq.artemis.core.client.impl with parameters of type ClientConsumerInternalModifier and TypeMethodDescriptionvoidClientSessionImpl.addConsumer(ClientConsumerInternal consumer) voidClientSessionInternal.addConsumer(ClientConsumerInternal consumer) voidClientMessageImpl.onReceipt(ClientConsumerInternal consumer) voidClientMessageInternal.onReceipt(ClientConsumerInternal consumer) voidClientSessionImpl.removeConsumer(ClientConsumerInternal consumer) voidClientSessionInternal.removeConsumer(ClientConsumerInternal consumer) Constructors in org.apache.activemq.artemis.core.client.impl with parameters of type ClientConsumerInternalModifierConstructorDescriptionLargeMessageControllerImpl(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 ClientConsumerInternalModifier and TypeMethodDescriptionActiveMQSessionContext.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 ClientConsumerInternalModifier and TypeMethodDescriptionvoidActiveMQSessionContext.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 ClientConsumerInternalModifier and TypeMethodDescriptionHornetQClientSessionContext.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 ClientConsumerInternalModifier and TypeMethodDescriptionabstract ClientConsumerInternalSessionContext.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 ClientConsumerInternalModifier and TypeMethodDescriptionabstract voidSessionContext.recreateConsumerOnServer(ClientConsumerInternal consumerInternal, long consumerId, boolean isSessionStarted)