Uses of Class
org.apache.activemq.command.ConsumerInfo

Packages that use ConsumerInfo
org.apache.activemq The core JMS client API implementation classes. 
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.util Some utility Broker Plugins 
org.apache.activemq.broker.view Broker Plugins for visualising the current system 
org.apache.activemq.command Command objects used via the Command Pattern to communicate among nodes 
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.state   
org.apache.activemq.transport.stomp An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different languages like Ruby, Python, PHP, C etc. 
org.apache.activemq.transport.xmpp   
 

Uses of ConsumerInfo in org.apache.activemq
 

Fields in org.apache.activemq declared as ConsumerInfo
protected  ConsumerInfo ActiveMQMessageConsumer.info
           
 

Methods in org.apache.activemq that return ConsumerInfo
 ConsumerInfo ActiveMQConnectionConsumer.getConsumerInfo()
           
 

Constructors in org.apache.activemq with parameters of type ConsumerInfo
ActiveMQConnectionConsumer(ActiveMQConnection theConnection, ServerSessionPool theSessionPool, ConsumerInfo theConsumerInfo)
          Create a ConnectionConsumer
 

Uses of ConsumerInfo in org.apache.activemq.advisory
 

Fields in org.apache.activemq.advisory with type parameters of type ConsumerInfo
protected  ConcurrentHashMap<ConsumerId,ConsumerInfo> AdvisoryBroker.consumers
           
 

Methods in org.apache.activemq.advisory that return ConsumerInfo
 ConsumerInfo ConsumerStartedEvent.getConsumerInfo()
           
 

Methods in org.apache.activemq.advisory that return types with arguments of type ConsumerInfo
 Map<ConsumerId,ConsumerInfo> AdvisoryBroker.getAdvisoryConsumers()
           
 

Methods in org.apache.activemq.advisory with parameters of type ConsumerInfo
 Subscription AdvisoryBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 void AdvisoryBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Constructors in org.apache.activemq.advisory with parameters of type ConsumerInfo
ConsumerStartedEvent(ConsumerEventSource source, ActiveMQDestination destination, ConsumerInfo consumerInfo, int count)
           
 

Uses of ConsumerInfo in org.apache.activemq.broker
 

Methods in org.apache.activemq.broker with parameters of type ConsumerInfo
 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)
           
 Response TransportConnection.processAddConsumer(ConsumerInfo info)
           
 void MutableBrokerFilter.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void ErrorBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void EmptyBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void BrokerFilter.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void BrokerBroadcaster.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

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

Methods in org.apache.activemq.broker.cluster with parameters of type ConsumerInfo
 Subscription ConnectionSplitBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 void ConnectionSplitBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

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

Methods in org.apache.activemq.broker.jmx that return ConsumerInfo
protected  ConsumerInfo SubscriptionView.getConsumerInfo()
           
protected  ConsumerInfo InactiveDurableSubscriptionView.getConsumerInfo()
           
 

Methods in org.apache.activemq.broker.jmx with parameters of type ConsumerInfo
 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)
           
static ObjectName BrokerMBeanSupport.createSubscriptionName(ObjectName brokerObjectName, String connectionClientId, ConsumerInfo info)
           
static ObjectName BrokerMBeanSupport.createSubscriptionName(String brokerObjectName, String connectionClientId, ConsumerInfo info)
           
protected  void ManagedRegionBroker.registerSubscription(ObjectName key, ConsumerInfo info, SubscriptionKey subscriptionKey, SubscriptionView view)
           
 void ManagedRegionBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

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

Fields in org.apache.activemq.broker.region declared as ConsumerInfo
protected  ConsumerInfo AbstractSubscription.info
           
 

Methods in org.apache.activemq.broker.region that return ConsumerInfo
 ConsumerInfo TopicRegion.createInactiveConsumerInfo(SubscriptionInfo info)
           
 ConsumerInfo Subscription.getConsumerInfo()
          The ConsumerInfo object that created the subscription.
 ConsumerInfo AbstractSubscription.getConsumerInfo()
           
 ConsumerInfo AbstractSubscription.getInfo()
           
 

Methods in org.apache.activemq.broker.region with parameters of type ConsumerInfo
 void DurableTopicSubscription.activate(SystemUsage memoryManager, ConnectionContext context, ConsumerInfo info, RegionBroker regionBroker)
           
 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)
           
 void TopicRegion.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void RegionBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void Region.removeConsumer(ConnectionContext context, ConsumerInfo info)
          Removes a consumer.
 void AbstractRegion.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Constructors in org.apache.activemq.broker.region with parameters of type ConsumerInfo
AbstractSubscription(Broker broker, ConnectionContext context, ConsumerInfo info)
           
DurableTopicSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, boolean keepDurableSubsActive)
           
PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info)
           
PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor)
           
QueueBrowserSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info)
           
QueueSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info)
           
TopicSubscription(Broker broker, ConnectionContext context, ConsumerInfo info, SystemUsage usageManager)
           
 

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

Methods in org.apache.activemq.broker.util with parameters of type ConsumerInfo
 Subscription UDPTraceBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription LoggingBrokerPlugin.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 Subscription DestinationPathSeparatorBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 void UDPTraceBrokerPlugin.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void LoggingBrokerPlugin.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 void DestinationPathSeparatorBroker.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

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

Methods in org.apache.activemq.broker.view with parameters of type ConsumerInfo
 Subscription ConnectionDotFileInterceptor.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 void ConnectionDotFileInterceptor.removeConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Uses of ConsumerInfo in org.apache.activemq.command
 

Methods in org.apache.activemq.command that return ConsumerInfo
 ConsumerInfo ConsumerInfo.copy()
           
 

Methods in org.apache.activemq.command with parameters of type ConsumerInfo
 void MessagePull.configure(ConsumerInfo info)
          Configures a message pull from the consumer information
 void ConsumerInfo.copy(ConsumerInfo info)
           
 

Constructors in org.apache.activemq.command with parameters of type ConsumerInfo
NetworkBridgeFilter(ConsumerInfo consumerInfo, BrokerId networkBrokerId, int networkTTL)
           
 

Uses of ConsumerInfo in org.apache.activemq.network
 

Fields in org.apache.activemq.network declared as ConsumerInfo
protected  ConsumerInfo DemandForwardingBridgeSupport.demandConsumerInfo
           
 

Methods in org.apache.activemq.network that return ConsumerInfo
 ConsumerInfo DemandSubscription.getLocalInfo()
           
 ConsumerInfo DemandSubscription.getRemoteInfo()
           
 

Methods in org.apache.activemq.network with parameters of type ConsumerInfo
protected  boolean DemandForwardingBridgeSupport.addConsumerInfo(ConsumerInfo consumerInfo)
           
protected  void DemandForwardingBridgeSupport.addRemoteBrokerToBrokerPath(ConsumerInfo info)
           
protected  boolean ConduitBridge.addToAlreadyInterestedConsumers(ConsumerInfo info)
           
protected  void DemandForwardingBridgeSupport.configureDemandSubscription(ConsumerInfo info, DemandSubscription sub)
           
 NetworkBridgeFilter NetworkBridgeFilterFactory.create(ConsumerInfo info, BrokerId[] remoteBrokerPath, int networkTimeToLive)
           
 NetworkBridgeFilter DefaultNetworkBridgeFilterFactory.create(ConsumerInfo info, BrokerId[] remoteBrokerPath, int networkTimeToLive)
           
 NetworkBridgeFilter ConditionalNetworkBridgeFilterFactory.create(ConsumerInfo info, BrokerId[] remoteBrokerPath, int networkTimeToLive)
           
protected  DemandSubscription DurableConduitBridge.createDemandSubscription(ConsumerInfo info)
           
protected  DemandSubscription DemandForwardingBridgeSupport.createDemandSubscription(ConsumerInfo info)
           
protected  DemandSubscription ConduitBridge.createDemandSubscription(ConsumerInfo info)
           
protected  NetworkBridgeFilter DemandForwardingBridgeSupport.createNetworkBridgeFilter(ConsumerInfo info)
           
protected  DemandSubscription DemandForwardingBridgeSupport.doCreateDemandSubscription(ConsumerInfo info)
           
 

Uses of ConsumerInfo in org.apache.activemq.plugin
 

Methods in org.apache.activemq.plugin with parameters of type ConsumerInfo
 Subscription SubQueueSelectorCacheBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Uses of ConsumerInfo in org.apache.activemq.security
 

Methods in org.apache.activemq.security with parameters of type ConsumerInfo
 Subscription AuthorizationBroker.addConsumer(ConnectionContext context, ConsumerInfo info)
           
 

Uses of ConsumerInfo in org.apache.activemq.state
 

Methods in org.apache.activemq.state that return ConsumerInfo
 ConsumerInfo ConsumerState.getInfo()
           
 

Methods in org.apache.activemq.state that return types with arguments of type ConsumerInfo
 Map<ConsumerId,ConsumerInfo> ConnectionState.getRecoveringPullConsumers()
           
 

Methods in org.apache.activemq.state with parameters of type ConsumerInfo
 void SessionState.addConsumer(ConsumerInfo info)
           
 Response ConnectionStateTracker.processAddConsumer(ConsumerInfo info)
           
 Response CommandVisitorAdapter.processAddConsumer(ConsumerInfo info)
           
 Response CommandVisitor.processAddConsumer(ConsumerInfo info)
           
 

Constructors in org.apache.activemq.state with parameters of type ConsumerInfo
ConsumerState(ConsumerInfo info)
           
 

Uses of ConsumerInfo in org.apache.activemq.transport.stomp
 

Fields in org.apache.activemq.transport.stomp declared as ConsumerInfo
protected  ConsumerInfo StompSubscription.consumerInfo
           
 

Methods in org.apache.activemq.transport.stomp that return ConsumerInfo
 ConsumerInfo StompSubscription.getConsumerInfo()
           
 

Constructors in org.apache.activemq.transport.stomp with parameters of type ConsumerInfo
StompQueueBrowserSubscription(ProtocolConverter stompTransport, String subscriptionId, ConsumerInfo consumerInfo, String transformation)
           
StompSubscription(ProtocolConverter stompTransport, String subscriptionId, ConsumerInfo consumerInfo, String transformation)
           
 

Uses of ConsumerInfo in org.apache.activemq.transport.xmpp
 

Method parameters in org.apache.activemq.transport.xmpp with type arguments of type ConsumerInfo
protected  void ProtocolConverter.subscribe(String to, ActiveMQDestination destination, Map<String,ConsumerInfo> consumerMap)
           
 



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