Uses of Class
org.activemq.message.ConsumerInfo

Packages that use ConsumerInfo
org.activemq The core JMS client implementation classes 
org.activemq.advisories Helper classes for listening to advisory messages. 
org.activemq.broker The API for the JMS Broker which is the server side of a JMS network though it may be deployed inside a client in peer style networks. 
org.activemq.broker.impl The default implementation of the JMS Broker 
org.activemq.security Plugable Security Adapter framework along with default implementations such as the JAAS implementation. 
org.activemq.security.jassjacc   
org.activemq.service The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager 
org.activemq.service.boundedvm   
org.activemq.service.impl Default implementations of the services 
org.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging 
org.activemq.store.cache   
org.activemq.store.jdbc Message persistence implemented using JDBC 
org.activemq.store.journal Message persistence using a high performance transaction log via the Journal interface. 
org.activemq.store.vm VM based implementation of message persistence 
org.activemq.transport The transport abstraction layer for sending and receiving Packets over a network 
 

Uses of ConsumerInfo in org.activemq
 

Methods in org.activemq that return ConsumerInfo
protected  ConsumerInfo ActiveMQSession.createConsumerInfo(ActiveMQMessageConsumer consumer)
           
 

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

Uses of ConsumerInfo in org.activemq.advisories
 

Methods in org.activemq.advisories that return ConsumerInfo
 ConsumerInfo ConsumerAdvisoryEvent.getInfo()
           
 

Uses of ConsumerInfo in org.activemq.broker
 

Methods in org.activemq.broker with parameters of type ConsumerInfo
 void Broker.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add an active message consumer, which could be rejected due to authorization
 void BrokerContainer.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerConnector.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void ConsumerInfoListener.onConsumerInfo(BrokerClient client, ConsumerInfo info)
          ConsumerInfo packet fired from within the broker
 void BrokerContainer.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerConnector.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void Broker.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
          remove an active message consumer
 

Uses of ConsumerInfo in org.activemq.broker.impl
 

Methods in org.activemq.broker.impl with parameters of type ConsumerInfo
 void DefaultBroker.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add an active message consumer
 void BrokerClientImpl.consumeConsumerInfo(ConsumerInfo info)
          Register/deregister MessageConsumer with the Broker
 void BrokerContainerImpl.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerConnectorImpl.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
protected  void DefaultBroker.fireConsumerInfo(BrokerClient client, ConsumerInfo info)
           
 void BrokerContainerImpl.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerConnectorImpl.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void DefaultBroker.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
          remove an active message consumer
protected  void DefaultBroker.validateConsumer(ConsumerInfo info)
          Ensures the consumer is valid, throwing a meaningful exception if not
 

Uses of ConsumerInfo in org.activemq.security
 

Methods in org.activemq.security with parameters of type ConsumerInfo
 void SecurityAdapter.authorizeConsumer(BrokerClient client, ConsumerInfo info)
          Authorizes that the consumer can start with the given consumer information
 

Uses of ConsumerInfo in org.activemq.security.jassjacc
 

Methods in org.activemq.security.jassjacc with parameters of type ConsumerInfo
 void JassJaccSecurityAdapter.authorizeConsumer(BrokerClient client, ConsumerInfo info)
           
 

Uses of ConsumerInfo in org.activemq.service
 

Methods in org.activemq.service with parameters of type ConsumerInfo
 void MessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 boolean Subscription.isSameDurableSubscription(ConsumerInfo info)
          Checks if this subscription is a duplicate durable subscription of the given consumer info
 Subscription SubscriptionContainer.makeSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
          Creates a subscription (which could be a previous subscription reconecting) and adds it to this container
 void MessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void Subscription.setActiveConsumer(BrokerClient client, ConsumerInfo info)
          Set the active consumer info
 void TopicMessageContainer.storeSubscription(ConsumerInfo info, Subscription subscription)
          Stores the persistence details in the database
 

Uses of ConsumerInfo in org.activemq.service.boundedvm
 

Fields in org.activemq.service.boundedvm declared as ConsumerInfo
protected  ConsumerInfo TransientSubscription.consumerInfo
           
protected  ConsumerInfo DurableSubscription.consumerInfo
           
 

Methods in org.activemq.service.boundedvm that return ConsumerInfo
 ConsumerInfo TransientSubscription.getConsumerInfo()
           
 ConsumerInfo DurableSubscription.getConsumerInfo()
           
 

Methods in org.activemq.service.boundedvm with parameters of type ConsumerInfo
 TransientTopicSubscription TransientTopicBoundedMessageContainer.addConsumer(Filter filter, ConsumerInfo info)
          Add a consumer to dispatch messages to
 TransientQueueSubscription TransientQueueBoundedMessageContainer.addConsumer(Filter filter, ConsumerInfo info, BrokerClient client)
          Add a consumer to dispatch messages to
 DurableQueueSubscription DurableQueueBoundedMessageContainer.addConsumer(Filter filter, ConsumerInfo info, BrokerClient client)
          Add a consumer to dispatch messages to
 void TransientQueueBoundedMessageManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add a consumer if appropiate
 void DurableQueueBoundedMessageManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add a consumer if appropiate
 void TransientTopicBoundedMessageManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add a consumer if appropiate
protected  Filter TransientQueueBoundedMessageManager.createFilter(ConsumerInfo info)
          Create filter for a Consumer
protected  Filter DurableQueueBoundedMessageManager.createFilter(ConsumerInfo info)
          Create filter for a Consumer
protected  Filter TransientTopicBoundedMessageManager.createFilter(ConsumerInfo info)
          Create filter for a Consumer
 void TransientQueueBoundedMessageContainer.removeConsumer(ConsumerInfo info)
          Remove a consumer
 void DurableQueueBoundedMessageContainer.removeConsumer(ConsumerInfo info)
          Remove a consumer
 void TransientTopicBoundedMessageContainer.removeConsumer(ConsumerInfo info)
          Remove a consumer
 void TransientQueueBoundedMessageManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void DurableQueueBoundedMessageManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void TransientTopicBoundedMessageManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void TransientSubscription.setConsumerInfo(ConsumerInfo consumerInfo)
           
 void DurableSubscription.setConsumerInfo(ConsumerInfo consumerInfo)
           
 

Constructors in org.activemq.service.boundedvm with parameters of type ConsumerInfo
DurableQueueSubscription(BrokerClient client, MemoryBoundedQueue dispatchedQueue, MemoryBoundedQueue ackQueue, Filter filter, ConsumerInfo info)
          Construct the DurableQueueSubscription
DurableSubscription(Filter filter, ConsumerInfo info, BrokerClient client)
          Construct the DurableSubscription
TransientQueueSubscription(BrokerClient client, MemoryBoundedQueue dispatchedQueue, MemoryBoundedQueue ackQueue, Filter filter, ConsumerInfo info)
          Construct the TransientQueueSubscription
TransientSubscription(Filter filter, ConsumerInfo info, BrokerClient client)
          Construct the TransientSubscription
TransientTopicSubscription(Filter filter, ConsumerInfo info, BrokerClient client)
          Construct the TransientTopicSubscription
 

Uses of ConsumerInfo in org.activemq.service.impl
 

Methods in org.activemq.service.impl with parameters of type ConsumerInfo
 void DurableQueueMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void DurableTopicMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void InitialImageMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void ProxyMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void TransientTopicMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
protected  Filter DurableQueueMessageContainerManager.createFilter(ConsumerInfo info)
          Create filter for a Consumer
protected  Filter DurableTopicMessageContainerManager.createFilter(ConsumerInfo info)
          Create filter for a Consumer
protected  Subscription DurableTopicSubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
protected  Subscription SubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
protected  void DurableTopicMessageContainerManager.doAddMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 boolean SubscriptionImpl.isSameDurableSubscription(ConsumerInfo info)
           
 Subscription SubscriptionContainerImpl.makeSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter)
           
 void DurableQueueMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void DurableTopicMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void ProxyMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void TransientTopicMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
protected  void InitialImageMessageContainerManager.sendMatchingInitialImages(BrokerClient client, ConsumerInfo info, DestinationFilter filter)
           
 void SubscriptionImpl.setActiveConsumer(BrokerClient client, ConsumerInfo info)
          Set the active consumer info
 void DurableTopicMessageContainer.storeSubscription(ConsumerInfo info, Subscription subscription)
           
 

Constructors in org.activemq.service.impl with parameters of type ConsumerInfo
DurableTopicSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter, RedeliveryPolicy redeliveryPolicy, DeadLetterPolicy deadLetterPolicy)
           
SubscriptionImpl(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter, RedeliveryPolicy redeliveryPolicy, DeadLetterPolicy deadLetterPolicy)
          Create a Subscription object that holds messages to be dispatched to a Consumer
 

Uses of ConsumerInfo in org.activemq.store
 

Methods in org.activemq.store with parameters of type ConsumerInfo
 SubscriberEntry TopicMessageStore.getSubscriberEntry(ConsumerInfo info)
          Finds the subscriber entry for the given consumer info
 SubscriberEntry ProxyTopicMessageStore.getSubscriberEntry(ConsumerInfo info)
           
 void TopicMessageStore.setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry)
          Inserts or updates the subscriber info due to a subscription change
 void ProxyTopicMessageStore.setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry)
           
 

Uses of ConsumerInfo in org.activemq.store.cache
 

Methods in org.activemq.store.cache with parameters of type ConsumerInfo
 SubscriberEntry CacheTopicMessageStore.getSubscriberEntry(ConsumerInfo info)
           
 void CacheTopicMessageStore.setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry)
           
 

Uses of ConsumerInfo in org.activemq.store.jdbc
 

Methods in org.activemq.store.jdbc with parameters of type ConsumerInfo
 SubscriberEntry JDBCTopicMessageStore.getSubscriberEntry(ConsumerInfo info)
           
 void JDBCTopicMessageStore.setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry)
           
 

Uses of ConsumerInfo in org.activemq.store.journal
 

Methods in org.activemq.store.journal with parameters of type ConsumerInfo
 SubscriberEntry JournalTopicMessageStore.getSubscriberEntry(ConsumerInfo info)
           
 void JournalTopicMessageStore.setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry)
           
 

Uses of ConsumerInfo in org.activemq.store.vm
 

Methods in org.activemq.store.vm with parameters of type ConsumerInfo
 SubscriberEntry VMTopicMessageStore.getSubscriberEntry(ConsumerInfo info)
           
 void VMTopicMessageStore.setSubscriberEntry(ConsumerInfo info, SubscriberEntry subscriberEntry)
           
 

Uses of ConsumerInfo in org.activemq.transport
 

Methods in org.activemq.transport with parameters of type ConsumerInfo
 void NetworkChannel.onConsumerInfo(BrokerClient client, ConsumerInfo info)
          Listen for new Consumer events at this broker
 



Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.