org.exolab.jms.messagemgr
Class DurableConsumerEndpoint

java.lang.Object
  extended by org.exolab.jms.messagemgr.ConsumerEndpoint
      extended by org.exolab.jms.messagemgr.TopicConsumerEndpoint
          extended by org.exolab.jms.messagemgr.DurableConsumerEndpoint
All Implemented Interfaces:
java.io.Serializable, java.lang.Runnable, Identifiable, DestinationCacheEventListener, DestinationEventListener

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

Field Summary
 
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


Copyright © 1999-2005 The OpenJMS Group. All Rights Reserved.