Uses of Class
org.codehaus.activemq.message.ConsumerInfo

Packages that use ConsumerInfo
org.codehaus.activemq The core JMS client implementation classes 
org.codehaus.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.codehaus.activemq.broker.impl The default implementation of the JMS Broker  
org.codehaus.activemq.security Plugable Security Adapter framework along with default implementations such as the JAAS implementation. 
org.codehaus.activemq.service The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager  
org.codehaus.activemq.service.boundedvm   
org.codehaus.activemq.service.impl Default implementations of the services  
org.codehaus.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging  
org.codehaus.activemq.store.bdb Message persistence implemented using Berkeley DB Java Edition  
org.codehaus.activemq.store.bdbn Message persistence implemented using Berkeley DB, native C version  
org.codehaus.activemq.store.cache   
org.codehaus.activemq.store.jdbc Message persistence implemented using JDBC  
org.codehaus.activemq.store.jdbm Message persistence implemented using JDBM which is the default persistence mechanism shipped with Geronimo (due to its BSD licence)  
org.codehaus.activemq.store.vm VM based implementation of message persistence  
org.codehaus.activemq.transport The transport abstraction layer for sending and receiving Packets over a network  
 

Uses of ConsumerInfo in org.codehaus.activemq
 

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

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

Uses of ConsumerInfo in org.codehaus.activemq.broker
 

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

Uses of ConsumerInfo in org.codehaus.activemq.broker.impl
 

Methods in org.codehaus.activemq.broker.impl with parameters of type ConsumerInfo
 void DefaultBroker.addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add an active message consumer
 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
protected  void DefaultBroker.fireConsumerInfo(BrokerClient client, ConsumerInfo info)
           
 void BrokerContainerImpl.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerContainerImpl.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerConnectorImpl.registerMessageConsumer(BrokerClient client, ConsumerInfo info)
          Registers a MessageConsumer
 void BrokerConnectorImpl.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void BrokerClientImpl.consumeConsumerInfo(ConsumerInfo info)
          Register/deregister MessageConsumer with the Broker
 

Uses of ConsumerInfo in org.codehaus.activemq.security
 

Methods in org.codehaus.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.codehaus.activemq.service
 

Methods in org.codehaus.activemq.service with parameters of type ConsumerInfo
 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.addMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void MessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void Subscription.setActiveConsumer(BrokerClient client, ConsumerInfo info)
          Set the active consumer info
 boolean Subscription.isSameDurableSubscription(ConsumerInfo info)
          Checks if this subscription is a duplicate durable subscription of the given consumer info
 void TopicMessageContainer.storeSubscription(ConsumerInfo info, Subscription subscription)
          Stores the persistence details in the database
 

Uses of ConsumerInfo in org.codehaus.activemq.service.boundedvm
 

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

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

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

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

Uses of ConsumerInfo in org.codehaus.activemq.service.impl
 

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

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

Uses of ConsumerInfo in org.codehaus.activemq.store
 

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

Uses of ConsumerInfo in org.codehaus.activemq.store.bdb
 

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

Uses of ConsumerInfo in org.codehaus.activemq.store.bdbn
 

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

Uses of ConsumerInfo in org.codehaus.activemq.store.cache
 

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

Uses of ConsumerInfo in org.codehaus.activemq.store.jdbc
 

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

Uses of ConsumerInfo in org.codehaus.activemq.store.jdbm
 

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

Uses of ConsumerInfo in org.codehaus.activemq.store.vm
 

Methods in org.codehaus.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.codehaus.activemq.transport
 

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



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