org.codehaus.activemq.service.impl
Class DurableTopicSubscription

java.lang.Object
  extended byorg.codehaus.activemq.service.impl.SubscriptionImpl
      extended byorg.codehaus.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.12 $

Field Summary
 
Fields inherited from class org.codehaus.activemq.service.impl.SubscriptionImpl
brokerName, clusterName, dispatch, filter, messagePtrs, unconsumedMessagesDispatched
 
Constructor Summary
DurableTopicSubscription(Dispatcher dispatcher, BrokerClient client, ConsumerInfo info, Filter filter, RedeliveryPolicy redeliveryPolicy)
           
 
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
 void redeliverMessage(MessageContainer container, MessageAck ack)
          Forces the given message to be redelivered
 
Methods inherited from class org.codehaus.activemq.service.impl.SubscriptionImpl
addMessage, clear, clientIDsEqual, createSubscriptionEntry, doMessageConsume, equal, getClientId, getConsumerId, getConsumerNumber, getDestination, getFilter, getLastMessageIdentity, getMessagesToDispatch, getMessagesWithPrefetch, getRedeliveryPolicy, getSelector, getSubscriberName, getSubscriptionEntry, isActive, isAtPrefetchLimit, isBrowser, isDurableTopic, isNoLocal, isReadyToDispatch, isSameDurableSubscription, isTarget, isWildcard, onAcknowledgeTransactedMessageBeforeCommit, 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)
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

redeliverMessage

public void redeliverMessage(MessageContainer container,
                             MessageAck ack)
                      throws JMSException
Description copied from interface: Subscription
Forces the given message to be redelivered

Specified by:
redeliverMessage in interface Subscription
Overrides:
redeliverMessage in class SubscriptionImpl
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 Protique, Ltd.. All Rights Reserved.