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

Packages that use Subscription
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.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.plugin   
org.apache.activemq.security Plugable Security Adapter framework along with default implementations such as the JAAS implementation. 
 

Uses of Subscription in org.apache.activemq.advisory
 

Methods in org.apache.activemq.advisory that return Subscription
 Subscription AdvisoryBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Methods in org.apache.activemq.advisory with parameters of type Subscription
 void AdvisoryBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void AdvisoryBroker.messageExpired(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void AdvisoryBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 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
 Subscription MutableBrokerFilter.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription ErrorBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription EmptyBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription BrokerFilter.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription BrokerBroadcaster.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription ConsumerBrokerExchange.getSubscription()
           
 

Methods in org.apache.activemq.broker with parameters of type Subscription
 void MutableBrokerFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void ErrorBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void EmptyBroker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void BrokerFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void Broker.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
          Called when a message is discarded - e.g.
 void MutableBrokerFilter.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void ErrorBroker.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void EmptyBroker.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void BrokerFilter.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void Broker.messageExpired(ConnectionContext context, MessageReference messageReference, Subscription subscription)
          A Message has Expired
 void MutableBrokerFilter.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void ErrorBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void EmptyBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void BrokerFilter.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void Broker.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
          A message needs to go the a DLQ
 void ConsumerBrokerExchange.setSubscription(Subscription subscription)
           
 void MutableBrokerFilter.slowConsumer(ConnectionContext context, Destination dest, Subscription subs)
           
 void ErrorBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 void EmptyBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 void BrokerFilter.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 void Broker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
          Called when there is a slow consumer
 

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

Methods in org.apache.activemq.broker.cluster that return Subscription
 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
protected  Subscription SubscriptionView.subscription
           
 

Methods in org.apache.activemq.broker.jmx that return Subscription
 Subscription ManagedRegionBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedTempTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedTempQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
 Subscription ManagedRegionBroker.getSubscriber(ObjectName key)
           
 

Methods in org.apache.activemq.broker.jmx with parameters of type Subscription
protected  void ManagedRegionBroker.addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info, Subscription subscription)
           
protected  void ManagedTopicRegion.destroySubscription(Subscription sub)
           
protected  void ManagedTempTopicRegion.destroySubscription(Subscription sub)
           
protected  void ManagedTempQueueRegion.destroySubscription(Subscription sub)
           
protected  void ManagedQueueRegion.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
DurableSubscriptionView(ManagedRegionBroker broker, String clientId, String userName, Subscription sub)
          Constructor
InactiveDurableSubscriptionView(ManagedRegionBroker broker, 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
 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
protected  CopyOnWriteArrayList<Subscription> Topic.consumers
           
protected  List<Subscription> Queue.consumers
           
protected  Map<ConsumerId,Subscription> AbstractRegion.subscriptions
           
 

Methods in org.apache.activemq.broker.region that return Subscription
 Subscription TopicRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription RegionBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription Region.addConsumer(ConnectionContext context, ConsumerInfo info)
          Adds a consumer.
 Subscription AbstractRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription TopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription TempTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription TempQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription QueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected abstract  Subscription AbstractRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
 Subscription QueueDispatchSelector.getExclusiveConsumer()
           
 

Methods in org.apache.activemq.broker.region that return types with arguments of type Subscription
protected  List<Subscription> TopicRegion.addSubscriptionsForDestination(ConnectionContext context, Destination dest)
           
protected  List<Subscription> AbstractRegion.addSubscriptionsForDestination(ConnectionContext context, Destination dest)
           
 List<Subscription> Topic.getConsumers()
           
 List<Subscription> Queue.getConsumers()
           
 List<Subscription> DestinationFilter.getConsumers()
           
 List<Subscription> Destination.getConsumers()
           
abstract  List<Subscription> BaseDestination.getConsumers()
           
 Map<ConsumerId,Subscription> AbstractRegion.getSubscriptions()
           
 

Methods in org.apache.activemq.broker.region with parameters of type Subscription
 void Topic.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Queue.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void DestinationFilter.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Destination.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Topic.addSubscription(ConnectionContext context, Subscription sub)
           
 void TempTopic.addSubscription(ConnectionContext context, Subscription sub)
           
 void TempQueue.addSubscription(ConnectionContext context, Subscription sub)
           
 void Queue.addSubscription(ConnectionContext context, Subscription sub)
           
 void DestinationFilter.addSubscription(ConnectionContext context, Subscription sub)
           
 void Destination.addSubscription(ConnectionContext context, Subscription sub)
           
 void BaseDestination.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)
           
 boolean QueueDispatchSelector.isExclusiveConsumer(Subscription s)
           
 void DestinationFilter.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void Destination.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
          Called when a message is discarded - e.g.
 void BaseDestination.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
          Called when a message is discarded - e.g.
 void RegionBroker.messageExpired(ConnectionContext context, MessageReference node, Subscription subscription)
           
 void Topic.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
           
 void Queue.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
           
 void DestinationFilter.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
           
 void Destination.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
          Inform the Destination a message has expired
protected  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 Topic.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void Queue.removeSubscription(ConnectionContext context, Subscription sub, long lastDeiveredSequenceId)
           
 void DestinationFilter.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void Destination.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void BaseDestination.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void RegionBroker.sendToDeadLetterQueue(ConnectionContext context, MessageReference node, Subscription subscription)
           
 void QueueDispatchSelector.setExclusiveConsumer(Subscription exclusiveConsumer)
           
 void DestinationFilter.slowConsumer(ConnectionContext context, Subscription subs)
           
 void Destination.slowConsumer(ConnectionContext context, Subscription subs)
          Called when there is a slow consumer
 void BaseDestination.slowConsumer(ConnectionContext context, Subscription subs)
          Called when there is a slow consumer
 

Method parameters in org.apache.activemq.broker.region with type arguments of type Subscription
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 with parameters of type Subscription
static boolean AbstractPendingMessageCursor.isPrioritizedMessageSubscriber(Broker broker, Subscription sub)
           
 

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

Methods in org.apache.activemq.broker.region.policy that return types with arguments of type Subscription
 Map<Subscription,SlowConsumerEntry> AbortSlowConsumerStrategy.getSlowConsumers()
           
 

Methods in org.apache.activemq.broker.region.policy with parameters of type Subscription
 void AbortSlowConsumerStrategy.abortConsumer(Subscription sub, boolean abortSubscriberConnection)
           
 boolean SimpleDispatchSelector.canDispatch(Subscription subscription, MessageReference node)
           
 boolean DispatchSelector.canDispatch(Subscription subscription, MessageReference node)
          return true if a subscription can dispatch a message reference
 void PolicyEntry.configurePrefetch(Subscription subscription)
           
protected  ActiveMQDestination IndividualDeadLetterStrategy.createDestination(Message message, String prefix, String suffix, boolean useQueue, Subscription subscription)
           
 ActiveMQDestination SharedDeadLetterStrategy.getDeadLetterQueueFor(Message message, Subscription subscription)
           
 ActiveMQDestination IndividualDeadLetterStrategy.getDeadLetterQueueFor(Message message, Subscription subscription)
           
 ActiveMQDestination DeadLetterStrategy.getDeadLetterQueueFor(Message message, Subscription subscription)
          Returns the dead letter queue for the given message and subscription.
 PendingMessageCursor VMPendingSubscriberMessageStoragePolicy.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 FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
           
 void SlowConsumerStrategy.slowConsumer(ConnectionContext context, Subscription subs)
           
 void AbortSlowConsumerStrategy.slowConsumer(ConnectionContext context, Subscription subs)
           
 

Method parameters in org.apache.activemq.broker.region.policy with type arguments of type Subscription
 boolean SimpleDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
           
 boolean RoundRobinDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
           
 boolean PriorityNetworkDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
           
 boolean PriorityDispatchPolicy.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.
 

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

Methods in org.apache.activemq.broker.util that return Subscription
 Subscription UDPTraceBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription LoggingBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription DestinationPathSeparatorBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Methods in org.apache.activemq.broker.util with parameters of type Subscription
 void LoggingBrokerPlugin.messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
           
 void LoggingBrokerPlugin.messageExpired(ConnectionContext context, MessageReference message, Subscription subscription)
           
 void RedeliveryPlugin.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 void LoggingBrokerPlugin.sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
           
 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
 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
 List<MessageReference> DestinationBasedMessageList.getMessages(Subscription sub)
           
 

Uses of Subscription in org.apache.activemq.plugin
 

Methods in org.apache.activemq.plugin that return Subscription
 Subscription SubQueueSelectorCacheBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Methods in org.apache.activemq.plugin with parameters of type Subscription
 void DiscardingDLQBroker.sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription)
           
 

Uses of Subscription in org.apache.activemq.security
 

Methods in org.apache.activemq.security that return Subscription
 Subscription AuthorizationBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 



Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.