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

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

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