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.ft Helper classes for implementing fault tolerance 
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.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.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 EmptyBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription MutableBrokerFilter.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription BrokerFilter.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription BrokerBroadcaster.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
 void ConsumerBrokerExchange.setSubscription(Subscription subscription)
           
 void Broker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
          Called when there is a slow consumer
 void EmptyBroker.slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
           
 void MutableBrokerFilter.slowConsumer(ConnectionContext context, Destination dest, Subscription subs)
           
 void BrokerFilter.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
 Subscription ConnectionSplitBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 

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

Methods in org.apache.activemq.broker.ft that return Subscription
 Subscription MasterBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
          add a consumer
 

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
protected  Subscription ManagedTempQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedQueueRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription ManagedTempTopicRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
 

Methods in org.apache.activemq.broker.jmx with parameters of type Subscription
protected  void ManagedTempQueueRegion.destroySubscription(Subscription sub)
           
protected  void ManagedTopicRegion.destroySubscription(Subscription sub)
           
protected  void ManagedQueueRegion.destroySubscription(Subscription sub)
           
protected  void ManagedTempTopicRegion.destroySubscription(Subscription sub)
           
static String ManagedRegionBroker.getSubscriptionObjectName(Subscription sub, String connectionClientId, ObjectName brokerJmxObjectName)
           
 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, Subscription sub)
          Constructor
SubscriptionView(String clientId, 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 Region.addConsumer(ConnectionContext context, ConsumerInfo info)
          Adds a consumer.
 Subscription AbstractRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription TopicRegion.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription RegionBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
protected abstract  Subscription AbstractRegion.createSubscription(ConnectionContext context, ConsumerInfo info)
           
protected  Subscription TopicRegion.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)
           
 Subscription QueueDispatchSelector.getExclusiveConsumer()
           
 

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

Methods in org.apache.activemq.broker.region with parameters of type Subscription
 void Destination.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Topic.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 Destination.addSubscription(ConnectionContext context, Subscription sub)
           
 void Topic.addSubscription(ConnectionContext context, Subscription sub)
           
 void DestinationFilter.addSubscription(ConnectionContext context, Subscription sub)
           
 void TempTopic.addSubscription(ConnectionContext context, Subscription sub)
           
 void Queue.addSubscription(ConnectionContext context, Subscription sub)
           
 void TempQueue.addSubscription(ConnectionContext context, Subscription sub)
           
protected  void QueueDispatchSelector.assignGroup(Subscription subs, MessageGroupMap messageGroupOwners, MessageReference n, String groupId)
           
 boolean QueueDispatchSelector.canSelect(Subscription subscription, MessageReference m)
           
protected  void AbstractRegion.destroySubscription(Subscription sub)
           
 boolean QueueDispatchSelector.isExclusiveConsumer(Subscription s)
           
 void Destination.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
          Inform the Destination a message has expired
 void Topic.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
           
 void DestinationFilter.messageExpired(ConnectionContext context, Subscription subs, MessageReference node)
           
 void Queue.messageExpired(ConnectionContext context, Subscription subs, MessageReference reference)
           
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 Destination.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void Topic.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void DestinationFilter.removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
           
 void Queue.removeSubscription(ConnectionContext context, Subscription sub, long lastDeiveredSequenceId)
           
 void QueueDispatchSelector.setExclusiveConsumer(Subscription exclusiveConsumer)
           
 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
 void DestinationFilter.slowConsumer(ConnectionContext context, Subscription subs)
           
 

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

Constructors in org.apache.activemq.broker.region.cursors with parameters of type Subscription
StoreDurableSubscriberCursor(Broker broker, String clientId, String subscriberName, int maxBatchSize, Subscription subscription)
           
 

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

Methods in org.apache.activemq.broker.region.policy with parameters of type Subscription
 boolean SimpleDispatchSelector.canDispatch(Subscription subscription, MessageReference node)
           
 boolean DispatchSelector.canDispatch(Subscription subscription, MessageReference node)
          return true if a subscription can dispatch a message reference
 PendingMessageCursor PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, Subscription sub)
          Retrieve the configured pending message storage cursor;
 PendingMessageCursor VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, Subscription sub)
          Retrieve the configured pending message storage cursor;
 PendingMessageCursor FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, Subscription sub)
          Retrieve the configured pending message storage cursor;
 PendingMessageCursor StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, Subscription sub)
          Retrieve the configured pending message storage cursor;
 

Method parameters in org.apache.activemq.broker.region.policy with type arguments of type Subscription
 boolean DispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
          Decides how to dispatch a selected message to a collection of consumers.
 boolean SimpleDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
           
 boolean RoundRobinDispatchPolicy.dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> 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)
           
 

Methods in org.apache.activemq.broker.util with parameters of type 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.security
 

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



Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.