|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |