Uses of Interface
org.apache.activemq.broker.region.Subscription

Packages that use Subscription

Package	Description
org.apache.activemq.advisory	Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.
org.apache.activemq.broker	The core classes for the ActiveMQ Message Broker and its connectors.
org.apache.activemq.broker.cluster
org.apache.activemq.broker.jmx	JMX MBeans for the broker and its core connectors.
org.apache.activemq.broker.region	Region abstraction and implementations in the Broker.
org.apache.activemq.broker.region.cursors	Cursors used to page persistent messages into the broker from the store
org.apache.activemq.broker.region.policy	The policies which can be associated with a particular destination or wildcard.
org.apache.activemq.broker.region.virtual	Implementation classes for Virtual Destinations
org.apache.activemq.broker.util	Some utility Broker Plugins
org.apache.activemq.broker.view	Broker Plugins for visualising the current system
org.apache.activemq.memory.list
org.apache.activemq.network	Support for federated networks of brokers.
org.apache.activemq.plugin
org.apache.activemq.security	Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
org.apache.activemq.shiro.authz

Uses of Subscription in org.apache.activemq.advisory

Methods in org.apache.activemq.advisory that return Subscription

Modifier and Type	Method	Description
Subscription	AdvisoryBroker.addConsumer(ConnectionContext context, ConsumerInfo info)

Methods in org.apache.activemq.advisory with parameters of type Subscription

Modifier and Type	Method	Description
void	AdvisoryBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
void	AdvisoryBroker.messageExpired(ConnectionContext context, MessageReference messageReference, Subscription subscription)
boolean	AdvisoryBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)
void	AdvisoryBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)

Uses of Subscription in org.apache.activemq.broker

Methods in org.apache.activemq.broker that return Subscription

Modifier and Type	Method	Description
Subscription	BrokerBroadcaster.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	BrokerFilter.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	EmptyBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	ErrorBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	ConsumerBrokerExchange.getSubscription()

Methods in org.apache.activemq.broker with parameters of type Subscription

Modifier and Type	Method	Description
void	Broker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)	Called when a message is discarded - e.g.
void	BrokerFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
void	EmptyBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
void	ErrorBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
void	Broker.messageExpired(ConnectionContext context, MessageReference messageReference, Subscription subscription)	A Message has Expired
void	BrokerFilter.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
void	EmptyBroker.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
void	ErrorBroker.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
boolean	Broker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)	A message needs to go the a DLQ
boolean	BrokerFilter.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)
boolean	EmptyBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)
boolean	ErrorBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)
void	ConsumerBrokerExchange.setSubscription(Subscription subscription)
void	Broker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)	Called when there is a slow consumer
void	BrokerFilter.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
void	EmptyBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
void	ErrorBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)

Uses of Subscription in org.apache.activemq.broker.cluster

Methods in org.apache.activemq.broker.cluster that return Subscription

Modifier and Type	Method	Description
Subscription	ConnectionSplitBroker.addConsumer(ConnectionContext context, ConsumerInfo info)

Uses of Subscription in org.apache.activemq.broker.jmx

Fields in org.apache.activemq.broker.jmx declared as Subscription

Modifier and Type	Field	Description
protected Subscription	SubscriptionView.subscription

Methods in org.apache.activemq.broker.jmx that return Subscription

Modifier and Type	Method	Description
Subscription	ManagedRegionBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
protected Subscription	ManagedQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
protected Subscription	ManagedTempQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
protected Subscription	ManagedTempTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
protected Subscription	ManagedTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
Subscription	ManagedRegionBroker.getSubscriber(ObjectName key)

Methods in org.apache.activemq.broker.jmx with parameters of type Subscription

Modifier and Type	Method	Description
protected void	ManagedRegionBroker.addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info, Subscription subscription)
protected void	ManagedQueueRegion.destroySubscription(Subscription sub)
protected void	ManagedTempQueueRegion.destroySubscription(Subscription sub)
protected void	ManagedTempTopicRegion.destroySubscription(Subscription sub)
protected void	ManagedTopicRegion.destroySubscription(Subscription sub)
ObjectName	ManagedRegionBroker.getSubscriberObjectName(Subscription key)
ObjectName	ManagedRegionBroker.registerSubscription(ConnectionContext context, Subscription sub)
void	ManagedRegionBroker.unregisterSubscription(Subscription sub)

Constructors in org.apache.activemq.broker.jmx with parameters of type Subscription

Constructor	Description
DurableSubscriptionView(ManagedRegionBroker broker, BrokerService brokerService, String clientId, String userName, Subscription sub)	Constructor
InactiveDurableSubscriptionView(ManagedRegionBroker broker, BrokerService brokerService, String clientId, SubscriptionInfo subInfo, Subscription subscription)	Constructor
SubscriptionView(String clientId, String userName, Subscription subs)	Constructor

Uses of Subscription in org.apache.activemq.broker.region

Classes in org.apache.activemq.broker.region that implement Subscription

Modifier and Type	Class	Description
class	AbstractSubscription
class	DurableTopicSubscription
class	PrefetchSubscription	A subscription that honors the pre-fetch option of the ConsumerInfo.
class	QueueBrowserSubscription
class	QueueSubscription
class	TopicSubscription

Fields in org.apache.activemq.broker.region with type parameters of type Subscription

Modifier and Type	Field	Description
protected List<Subscription>	Queue.consumers
protected CopyOnWriteArrayList<Subscription>	Topic.consumers
protected Map<ConsumerId,Subscription>	AbstractRegion.subscriptions

Methods in org.apache.activemq.broker.region that return Subscription

Modifier and Type	Method	Description
Subscription	AbstractRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	Region.addConsumer(ConnectionContext context, ConsumerInfo info)	Adds a consumer.
Subscription	RegionBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	TopicRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
protected abstract Subscription	AbstractRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
protected Subscription	QueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
protected Subscription	TempQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
protected Subscription	TempTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
protected Subscription	TopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
Subscription	QueueDispatchSelector.getExclusiveConsumer()

Methods in org.apache.activemq.broker.region that return types with arguments of type Subscription

Modifier and Type	Method	Description
protected List<Subscription>	AbstractRegion.addSubscriptionsForDestination(ConnectionContext context, Destination dest)
protected List<Subscription>	TopicRegion.addSubscriptionsForDestination(ConnectionContext context, Destination dest)
abstract List<Subscription>	BaseDestination.getConsumers()
List<Subscription>	Destination.getConsumers()
List<Subscription>	DestinationFilter.getConsumers()
List<Subscription>	Queue.getConsumers()
List<Subscription>	Topic.getConsumers()
Map<ConsumerId,Subscription>	AbstractRegion.getSubscriptions()

Methods in org.apache.activemq.broker.region with parameters of type Subscription

Modifier and Type	Method	Description
void	Destination.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
void	DestinationFilter.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
void	Queue.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
void	Topic.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
void	BaseDestination.addSubscription(ConnectionContext context, Subscription sub)
void	Destination.addSubscription(ConnectionContext context, Subscription sub)
void	DestinationFilter.addSubscription(ConnectionContext context, Subscription sub)
void	Queue.addSubscription(ConnectionContext context, Subscription sub)
void	TempQueue.addSubscription(ConnectionContext context, Subscription sub)
void	TempTopic.addSubscription(ConnectionContext context, Subscription sub)
void	Topic.addSubscription(ConnectionContext context, Subscription sub)
protected void	Queue.assignGroup(Subscription subs, MessageGroupMap messageGroupOwners, MessageReference n, String groupId)
protected boolean	Queue.assignMessageGroup(Subscription subscription, QueueMessageReference node)
boolean	QueueDispatchSelector.canSelect(Subscription subscription, MessageReference m)
protected void	AbstractRegion.destroySubscription(Subscription sub)
void	BaseDestination.duplicateFromStore(Message message, Subscription subscription)
void	Destination.duplicateFromStore(Message message, Subscription subscription)
void	DestinationFilter.duplicateFromStore(Message message, Subscription subscription)
boolean	QueueDispatchSelector.isExclusiveConsumer(Subscription s)
void	BaseDestination.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)	Called when a message is discarded - e.g.
void	Destination.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)	Called when a message is discarded - e.g.
void	DestinationFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
void	Destination.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)	Inform the Destination a message has expired
void	DestinationFilter.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
void	Queue.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
void	RegionBroker.messageExpired(ConnectionContext context, MessageReference node, Subscription subscription)
void	Topic.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
void	Topic.recoverRetroactiveMessages(ConnectionContext context, Subscription subscription)
protected void	Queue.removeMessage(ConnectionContext c, Subscription subs, QueueMessageReference r)
protected void	Queue.removeMessage(ConnectionContext context, Subscription sub, QueueMessageReference reference, MessageAck ack)
void	BaseDestination.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
void	Destination.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
void	DestinationFilter.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
void	Queue.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
void	Topic.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
boolean	RegionBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference node, Subscription subscription, Throwable poisonCause)
void	QueueDispatchSelector.setExclusiveConsumer(Subscription exclusiveConsumer)
void	BaseDestination.slowConsumer(ConnectionContext context, Subscription subs)	Called when there is a slow consumer
void	Destination.slowConsumer(ConnectionContext context, Subscription subs)	Called when there is a slow consumer
void	DestinationFilter.slowConsumer(ConnectionContext context, Subscription subs)

Method parameters in org.apache.activemq.broker.region with type arguments of type Subscription

Modifier and Type	Method	Description
protected boolean	BaseDestination.hasRegularConsumers(List<Subscription> consumers)

Uses of Subscription in org.apache.activemq.broker.region.cursors

Methods in org.apache.activemq.broker.region.cursors that return Subscription

Modifier and Type	Method	Description
Subscription	AbstractStoreCursor.getSubscription()

Methods in org.apache.activemq.broker.region.cursors with parameters of type Subscription

Modifier and Type	Method	Description
static boolean	AbstractPendingMessageCursor.isPrioritizedMessageSubscriber(Broker broker, Subscription sub)

Uses of Subscription in org.apache.activemq.broker.region.policy

Fields in org.apache.activemq.broker.region.policy with type parameters of type Subscription

Modifier and Type	Field	Description
protected Map<Subscription,SlowConsumerEntry>	AbortSlowConsumerStrategy.slowConsumers

Methods in org.apache.activemq.broker.region.policy that return types with arguments of type Subscription

Modifier and Type	Method	Description
Map<Subscription,SlowConsumerEntry>	AbortSlowConsumerStrategy.getSlowConsumers()

Methods in org.apache.activemq.broker.region.policy with parameters of type Subscription

Modifier and Type	Method	Description
void	AbortSlowConsumerStrategy.abortConsumer(Subscription sub, boolean abortSubscriberConnection)
boolean	DispatchSelector.canDispatch(Subscription subscription, MessageReference node)	return true if a subscription can dispatch a message reference
boolean	SimpleDispatchSelector.canDispatch(Subscription subscription, MessageReference node)
void	PolicyEntry.configurePrefetch(Subscription subscription)
protected ActiveMQDestination	IndividualDeadLetterStrategy.createDestination(Message message, String prefix, String suffix, boolean useQueue, Subscription subscription)
ActiveMQDestination	DeadLetterStrategy.getDeadLetterQueueFor(Message message, Subscription subscription)	Returns the dead letter queue for the given message and subscription.
ActiveMQDestination	IndividualDeadLetterStrategy.getDeadLetterQueueFor(Message message, Subscription subscription)
ActiveMQDestination	SharedDeadLetterStrategy.getDeadLetterQueueFor(Message message, Subscription subscription)
PendingMessageCursor	FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
PendingMessageCursor	PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)	Retrieve the configured pending message storage cursor;
PendingMessageCursor	VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
void	AbortSlowAckConsumerStrategy.slowConsumer(ConnectionContext context, Subscription subs)
void	AbortSlowConsumerStrategy.slowConsumer(ConnectionContext context, Subscription subs)
void	SlowConsumerStrategy.slowConsumer(ConnectionContext context, Subscription subs)	Slow consumer event.

Method parameters in org.apache.activemq.broker.region.policy with type arguments of type Subscription

Modifier and Type	Method	Description
protected void	AbortSlowConsumerStrategy.abortSubscription(Map<Subscription,SlowConsumerEntry> toAbort, boolean abortSubscriberConnection)
boolean	ClientIdFilterDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
boolean	DispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)	Decides how to dispatch a selected message to a collection of consumers.
boolean	PriorityDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
boolean	PriorityNetworkDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
boolean	RoundRobinDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
boolean	SimpleDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)

Uses of Subscription in org.apache.activemq.broker.region.virtual

Methods in org.apache.activemq.broker.region.virtual with parameters of type Subscription

Modifier and Type	Method	Description
void	MappedQueueFilter.addSubscription(ConnectionContext context, Subscription sub)
void	MappedQueueFilter.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)

Uses of Subscription in org.apache.activemq.broker.util

Methods in org.apache.activemq.broker.util that return Subscription

Modifier and Type	Method	Description
Subscription	DestinationPathSeparatorBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	LoggingBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)
Subscription	UDPTraceBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)

Methods in org.apache.activemq.broker.util with parameters of type Subscription

Modifier and Type	Method	Description
void	LoggingBrokerPlugin.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
void	LoggingBrokerPlugin.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
boolean	LoggingBrokerPlugin.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)
boolean	RedeliveryPlugin.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)
void	LoggingBrokerPlugin.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)

Uses of Subscription in org.apache.activemq.broker.view

Methods in org.apache.activemq.broker.view that return Subscription

Modifier and Type	Method	Description
Subscription	ConnectionDotFileInterceptor.addConsumer(ConnectionContext context, ConsumerInfo info)

Uses of Subscription in org.apache.activemq.memory.list

Methods in org.apache.activemq.memory.list with parameters of type Subscription

Modifier and Type	Method	Description
List<MessageReference>	DestinationBasedMessageList.getMessages(Subscription sub)

Uses of Subscription in org.apache.activemq.network

Methods in org.apache.activemq.network that return types with arguments of type Subscription

Modifier and Type	Method	Description
protected Collection<Subscription>	DemandForwardingBridgeSupport.getRegionSubscriptions(ActiveMQDestination dest)

Uses of Subscription in org.apache.activemq.plugin

Methods in org.apache.activemq.plugin that return Subscription

Modifier and Type	Method	Description
Subscription	SubQueueSelectorCacheBroker.addConsumer(ConnectionContext context, ConsumerInfo info)

Methods in org.apache.activemq.plugin with parameters of type Subscription

Modifier and Type	Method	Description
boolean	DiscardingDLQBroker.sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription, Throwable poisonCause)

Uses of Subscription in org.apache.activemq.security

Methods in org.apache.activemq.security that return Subscription

Modifier and Type	Method	Description
Subscription	AuthorizationBroker.addConsumer(ConnectionContext context, ConsumerInfo info)

Methods in org.apache.activemq.security with parameters of type Subscription

Modifier and Type	Method	Description
void	AuthorizationDestinationFilter.addSubscription(ConnectionContext context, Subscription sub)

Uses of Subscription in org.apache.activemq.shiro.authz

Methods in org.apache.activemq.shiro.authz that return Subscription

Modifier and Type	Method	Description
Subscription	AuthorizationFilter.addConsumer(ConnectionContext context, ConsumerInfo info)