org.activemq.service.impl
Class DurableTopicSubscription

java.lang.Object
  extended byorg.activemq.service.impl.SubscriptionImpl
      extended byorg.activemq.service.impl.DurableTopicSubscription
All Implemented Interfaces:
Subscription

public class DurableTopicSubscription
extends SubscriptionImpl

Represents a durable topic subscription where the consumer has a unique clientID used to persist the messages across both Broker restarts and JMS client restarts

Version:
$Revision: 1.1.1.1 $

Field Summary
 
Fields inherited from class org.activemq.service.impl.SubscriptionImpl
brokerName, clusterName, dispatch, lastMessageIdentity, messagePtrs, unconsumedMessagesDispatched
 
Constructor Summary
DurableTopicSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter, RedeliveryPolicy redeliveryPolicy, DeadLetterPolicy deadLetterPolicy)
           
 
Method Summary
 String getPersistentKey()
          Returns the persistent key used to uniquely identify this durable topic subscription
 void messageConsumed(MessageAck ack)
          Indicates a message has been delivered to a MessageConsumer
 
Methods inherited from class org.activemq.service.impl.SubscriptionImpl
addMessage, clear, clientIDsEqual, createSubscriptionEntry, equal, getActiveClient, getClientId, getConsumerId, getConsumerNumber, getDestination, getFilter, getLastMessageIdentity, getMessagesToDispatch, getMessagesWithPrefetch, getRedeliveryPolicy, getSelector, getSubscriberName, getSubscriptionEntry, isActive, isAtPrefetchLimit, isAuthorizedForMessage, isBrowser, isDurableTopic, isLocalSubscription, isNoLocal, isReadyToDispatch, isSameDurableSubscription, isTarget, isWildcard, reset, setActive, setActiveConsumer, setClientId, setFilter, setLastMessageIdentifier, setNoLocal, setRedeliveryPolicy, setSubscriberName, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

DurableTopicSubscription

public DurableTopicSubscription(Dispatcher dispatcher,
                                BrokerClient client,
                                ConsumerInfo info,
                                Filter filter,
                                RedeliveryPolicy redeliveryPolicy,
                                DeadLetterPolicy deadLetterPolicy)
Method Detail

messageConsumed

public void messageConsumed(MessageAck ack)
                     throws JMSException
Description copied from class: SubscriptionImpl
Indicates a message has been delivered to a MessageConsumer

Specified by:
messageConsumed in interface Subscription
Overrides:
messageConsumed in class SubscriptionImpl
Parameters:
ack -
Throws:
JMSException

getPersistentKey

public String getPersistentKey()
Description copied from interface: Subscription
Returns the persistent key used to uniquely identify this durable topic subscription

Specified by:
getPersistentKey in interface Subscription
Overrides:
getPersistentKey in class SubscriptionImpl


Copyright © 2004-2007 Protique, Ltd.. All Rights Reserved.