Uses of Interface
org.apache.activemq.artemis.core.server.Consumer
Packages that use Consumer
Package
Description
-
Uses of Consumer in org.apache.activemq.artemis.core.server
Subinterfaces of Consumer in org.apache.activemq.artemis.core.serverMethods in org.apache.activemq.artemis.core.server that return types with arguments of type ConsumerMethods in org.apache.activemq.artemis.core.server with parameters of type ConsumerModifier and TypeMethodDescriptionvoidQueue.addConsumer(Consumer consumer) default voidQueue.errorProcessing(Consumer consumer, Throwable t, MessageReference messageReference) voidQueue.removeConsumer(Consumer consumer) voidActiveMQServerLogger_impl.removingBadConsumer(Consumer consumer, Object reference, Throwable e) voidActiveMQServerLogger.removingBadConsumer(Consumer consumer, Object reference, Throwable e) -
Uses of Consumer in org.apache.activemq.artemis.core.server.cluster
Subinterfaces of Consumer in org.apache.activemq.artemis.core.server.cluster -
Uses of Consumer in org.apache.activemq.artemis.core.server.cluster.impl
Classes in org.apache.activemq.artemis.core.server.cluster.impl that implement ConsumerModifier and TypeClassDescriptionclassclassA bridge with extra functionality only available when the server is clustered.class -
Uses of Consumer in org.apache.activemq.artemis.core.server.impl
Classes in org.apache.activemq.artemis.core.server.impl with type parameters of type ConsumerModifier and TypeClassDescriptionprotected static classQueueImpl.ConsumerHolder<T extends Consumer>Classes in org.apache.activemq.artemis.core.server.impl that implement ConsumerModifier and TypeClassDescriptionclassConcrete implementation of a ClientConsumer.Methods in org.apache.activemq.artemis.core.server.impl that return types with arguments of type ConsumerModifier and TypeMethodDescriptionQueueImpl.getConsumers()QueueImpl.getGroups()static MessageGroups<Consumer>QueueImpl.groupMap(int groupBuckets) Methods in org.apache.activemq.artemis.core.server.impl with parameters of type ConsumerModifier and TypeMethodDescriptionvoidQueueImpl.addConsumer(Consumer consumer) voidQueueImpl.errorProcessing(Consumer consumer, Throwable t, MessageReference reference) This will print errors and decide what to do with the errored consumer from the protocol layer.voidQueueImpl.removeConsumer(Consumer consumer) Method parameters in org.apache.activemq.artemis.core.server.impl with type arguments of type ConsumerModifier and TypeMethodDescriptionprotected voidQueueImpl.removeMessageReference(QueueImpl.ConsumerHolder<? extends Consumer> holder, MessageReference ref)