|
||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of ConsumerEndpoint in org.exolab.jms.messagemgr |
Subclasses of ConsumerEndpoint in org.exolab.jms.messagemgr | |
class |
DurableConsumerEndpoint
A durable subscriber extends ConsumerEndpoint and is only associated
with a Topic destination. |
class |
QueueBrowserEndpoint
A QueueBrowserEndpoint is a QueueListener to a QueueDestinationCache. |
class |
QueueConsumerEndpoint
A QueueConsumerEndpoint extends ConsumerEndpoint . |
class |
TopicConsumerEndpoint
The topic destination cache is specific to a consumer that subscribes to a topic destination. |
Methods in org.exolab.jms.messagemgr that return ConsumerEndpoint | |
ConsumerEndpoint |
ConsumerManager.createConsumerEndpoint(JmsServerSession session,
long clientId,
JmsDestination destination,
java.lang.String selector)
Create a transient consumer for the specified destination. |
ConsumerEndpoint |
ConsumerManager.createQueueBrowserEndpoint(JmsServerSession session,
long clientId,
JmsQueue queue,
java.lang.String selector)
Create a browser for the specified destination and the selector. |
ConsumerEndpoint |
ConsumerManager.getConsumerEndpoint(java.lang.String id)
Return the consumer with the specified identity |
ConsumerEndpoint |
MessageMgr.resolveConsumer(JmsDestination destination,
java.lang.String id)
Resolves a consumer given its destination and an identity. |
Methods in org.exolab.jms.messagemgr with parameters of type ConsumerEndpoint | |
void |
ConsumerManager.deleteConsumerEndpoint(ConsumerEndpoint consumer)
Destroy the specified consumer |
boolean |
DestinationCache.registerConsumer(ConsumerEndpoint consumer)
Register a consumer with this cache. |
void |
DestinationCache.unregisterConsumer(ConsumerEndpoint consumer)
Remove the consumer for the list of registered consumers. |
static MessageHandle |
MessageHandleFactory.getHandle(ConsumerEndpoint consumer,
MessageImpl message)
Retrieve a message handle for the specified ConsumerEndpoint
and message. |
boolean |
MessageMgr.hasMessages(ConsumerEndpoint consumer)
Returns true if there are any messages for the specified consumer |
void |
MessageMgr.setStopped(ConsumerEndpoint consumer,
boolean stop)
Stop/start a consumer. |
boolean |
TopicDestinationCache.registerConsumer(ConsumerEndpoint consumer)
|
Uses of ConsumerEndpoint in org.exolab.jms.server |
Methods in org.exolab.jms.server that return ConsumerEndpoint | |
ConsumerEndpoint |
JmsServerSession.getConsumerEndpoint(long clientId)
Returns the consumer endpoint for the supplied client id |
|
||||||||
PREV NEXT | FRAMES NO FRAMES |