|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ConsumerEndpoint | |
org.exolab.jms.messagemgr |
Uses of ConsumerEndpoint in org.exolab.jms.messagemgr |
Classes in org.exolab.jms.messagemgr that implement ConsumerEndpoint | |
class |
AbstractConsumerEndpoint
Abstract implementation of the ConsumerEndpoint interface. |
(package private) class |
org.exolab.jms.messagemgr.AbstractTopicConsumerEndpoint
A ConsumerEndpoint for topics. |
class |
DurableConsumerEndpoint
A ConsumerEndpoint for durable topic consumers. |
class |
QueueBrowserEndpoint
A QueueBrowserEndpoint is a QueueListener to a QueueDestinationCache. |
class |
QueueConsumerEndpoint
A ConsumerEndpoint for queues. |
class |
TopicConsumerEndpoint
A ConsumerEndpoint for transient topic consumers. |
Methods in org.exolab.jms.messagemgr that return ConsumerEndpoint | |
ConsumerEndpoint |
ConsumerManager.createConsumer(JmsDestination destination,
long connectionId,
java.lang.String selector,
boolean noLocal)
Create a transient consumer for the specified destination. |
ConsumerEndpoint |
ConsumerManager.createQueueBrowser(JmsQueue queue,
java.lang.String selector)
Create a new queue browser. |
ConsumerEndpoint |
ConsumerManager.getConsumerEndpoint(long consumerId)
Return the consumer with the specified identity. |
ConsumerEndpoint |
ConsumerManager.getConsumerEndpoint(java.lang.String persistentId)
Return the consumer with the specified persistent identity. |
protected ConsumerEndpoint |
AbstractDestinationCache.getConsumerEndpoint(long consumerId)
Returns a consumer endpoint, given its id. |
protected ConsumerEndpoint[] |
AbstractDestinationCache.getConsumerArray()
Helper to return the consumers as an array. |
ConsumerEndpoint |
ConsumerManagerImpl.createConsumer(JmsDestination destination,
long connectionId,
java.lang.String selector,
boolean noLocal)
Create a transient consumer for the specified destination. |
ConsumerEndpoint |
ConsumerManagerImpl.createQueueBrowser(JmsQueue queue,
java.lang.String selector)
Create a browser for the specified destination and the selector. |
ConsumerEndpoint |
ConsumerManagerImpl.getConsumerEndpoint(long consumerId)
Return the consumer with the specified identity. |
ConsumerEndpoint |
ConsumerManagerImpl.getConsumerEndpoint(java.lang.String persistentId)
Return the consumer with the specified persistent identity. |
Methods in org.exolab.jms.messagemgr with parameters of type ConsumerEndpoint | |
boolean |
DestinationCache.addConsumer(ConsumerEndpoint consumer)
Register a consumer with this cache. |
void |
DestinationCache.removeConsumer(ConsumerEndpoint consumer)
Remove the consumer for the list of registered consumers. |
void |
ConsumerEndpointListener.messageAvailable(ConsumerEndpoint consumer)
Notifies that a message is available for a particular consumer. |
void |
ConsumerManager.closeConsumer(ConsumerEndpoint consumer)
Close a consumer. |
boolean |
AbstractDestinationCache.addConsumer(ConsumerEndpoint consumer)
Register a consumer with this cache. |
void |
AbstractDestinationCache.removeConsumer(ConsumerEndpoint consumer)
Remove the consumer for the list of registered consumers. |
void |
ConsumerManagerImpl.closeConsumer(ConsumerEndpoint consumer)
Close a consumer. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |