Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## 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.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.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

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` | `BrokerContainer.registerMessageConsumer(BrokerClient client, ConsumerInfo info)` Registers a MessageConsumer
`void` | `BrokerContainer.deregisterMessageConsumer(BrokerClient client, ConsumerInfo info)` De-register a MessageConsumer from the Broker
`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` | `Broker.addMessageConsumer(BrokerClient client, ConsumerInfo info)` Add an active message consumer
`void` | `Broker.removeMessageConsumer(BrokerClient client, ConsumerInfo info)` remove an active message consumer

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
`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.service

Methods in org.codehaus.activemq.service with parameters of type ConsumerInfo
`Subscription` | `SubscriptionContainer.makeSubscription(Dispatcher dispatcher, ConsumerInfo info, Filter filter)` Creates a subscription (which could be a previous subscription reconecting) and adds it to this container
`void` | `SubscriptionContainer.checkForDuplicateDurableSubscription(BrokerClient client, ConsumerInfo info)` There is only meant to be a single durable subscription open for a given clientID and subscriber name; this method will check to ensure that a user doesn't try to subscribe twice for the same clientID and subscriber name.
`void` | `Subscription.setActiveConsumer(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` | `MessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)`
`void` | `MessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)`

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

Methods in org.codehaus.activemq.service.boundedvm that return ConsumerInfo
`ConsumerInfo` | `TransientTopicSubscription.getConsumerInfo()`

Methods in org.codehaus.activemq.service.boundedvm with parameters of type ConsumerInfo
`void` | `TransientTopicSubscription.setConsumerInfo(ConsumerInfo 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

Constructors in org.codehaus.activemq.service.boundedvm with parameters of type ConsumerInfo
`TransientTopicSubscription(Filter filter, ConsumerInfo info)` Construct the TransientTopicSubscription

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

Methods in org.codehaus.activemq.service.impl with parameters of type ConsumerInfo
`void` | `TransientTopicMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)`
`void` | `TransientTopicMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)`
`void` | `SubscriptionImpl.setActiveConsumer(ConsumerInfo info)` Set the active consumer info
`boolean` | `SubscriptionImpl.isSameDurableSubscription(ConsumerInfo info)`
`Subscription` | `SubscriptionContainerImpl.makeSubscription(Dispatcher dispatcher, ConsumerInfo info, Filter filter)`
`void` | `SubscriptionContainerImpl.checkForDuplicateDurableSubscription(BrokerClient client, ConsumerInfo info)`
`protected Subscription` | `SubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, ConsumerInfo info, Filter filter)`
`void` | `QueueMessageContainerManager.addMessageConsumer(BrokerClient client, ConsumerInfo info)`
`void` | `QueueMessageContainerManager.removeMessageConsumer(BrokerClient client, ConsumerInfo info)`
`protected Filter` | `QueueMessageContainerManager.createFilter(ConsumerInfo info)` Create filter for a Consumer
`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)`
`protected Subscription` | `DurableTopicSubscriptionContainerImpl.createSubscription(Dispatcher dispatcher, ConsumerInfo info, Filter filter)`
`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, ConsumerInfo info, Filter filter)` Create a Subscription object that holds messages to be dispatched to a Consumer
`DurableTopicSubscription(Dispatcher dispatcher, ConsumerInfo info, Filter filter)`

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.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)`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

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