org.exolab.jms.messagemgr
Class DurableConsumerEndpoint

java.lang.Object
  |
  +--org.exolab.jms.messagemgr.ConsumerEndpoint
        |
        +--org.exolab.jms.messagemgr.TopicConsumerEndpoint
              |
              +--org.exolab.jms.messagemgr.DurableConsumerEndpoint

All Implemented Interfaces:

DestinationCacheEventListener, DestinationEventListener, Identifiable, java.lang.Runnable, java.io.Serializable

public class DurableConsumerEndpoint

extends TopicConsumerEndpoint

A durable subscriber extends ConsumerEndpoint and is only associated with a Topic destination. The state of the durable subscriber is maintained across server invocations by the persistent layer

Version:

$Revision: 1.22 $ $Date: 2003/09/25 11:24:16 $

Author:

Jim Alateras

See Also:

Serialized Form

Fields inherited from class org.exolab.jms.messagemgr.TopicConsumerEndpoint

_caches, _topic

Fields inherited from class org.exolab.jms.messagemgr.ConsumerEndpoint

_ackMode, _connectionId, _listener, _nolocal, _scheduler, _selector, _session, _size, _transacted, _waitingForMessage, _waitingForMessageMonitor

Method Summary

java.lang.String	getName() Returns the durable subscription name
java.lang.String	getPersistentId() Returns the persistent identifier for this consumer. This is the identity of the consumer which is persistent across subscriptions and server restarts.

Methods inherited from class org.exolab.jms.messagemgr.TopicConsumerEndpoint

deliverMessages, destinationAdded, destinationRemoved, doClose, getDestination, messageRemoved, persistentMessageRemoved, receiveMessage, receiveNoWait, recover, unregister

Methods inherited from class org.exolab.jms.messagemgr.ConsumerEndpoint

addMessage, addMessage, clearMessages, clearWaitingForMessage, close, collectGarbage, collectionHasPersistentHandles, containsMessage, deleteMessage, getAckMode, getClientId, getConnectionId, getId, getMaximumSize, getMessage, getMessageCount, getNoLocal, getSelector, getSession, getTransacted, hashCode, isStopped, isWaitingForMessage, messageAdded, notifyMessageAvailable, persistentMessageAdded, removeFirstMessage, removeMessage, returnMessage, run, schedule, setAckMode, setCacheEvictionPolicy, setConnectionId, setMaximumSize, setMessageListener, setNoLocal, setSelector, setStopped, setTransacted, setWaitingForMessage, stopDelivery, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

getPersistentId

public java.lang.String getPersistentId()

Returns the persistent identifier for this consumer.

This is the identity of the consumer which is persistent across subscriptions and server restarts.

This implementation returns the consumer name.

Overrides:

getPersistentId in class ConsumerEndpoint

Returns:

the persistent identifier for this consumer

getName

public java.lang.String getName()

Returns the durable subscription name

Returns:

the durable subscription name