Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> service >> [ impl overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.service.impl
Class DurableTopicSubscription  

java.lang.Object
  org.activemq.service.impl.SubscriptionImpl
      org.activemq.service.impl.DurableTopicSubscription

All Implemented Interfaces:

org.activemq.service.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
private static org.apache.commons.logging.Log	log
private  java.lang.String	persistentKey

 

Fields inherited from class org.activemq.service.impl.SubscriptionImpl

brokerName, clusterName, dispatch, lastMessageIdentity, messagePtrs, unconsumedMessagesDispatched

 

Constructor Summary

DurableTopicSubscription(org.activemq.service.Dispatcher dispatcher, org.activemq.broker.BrokerClient client, org.activemq.message.ConsumerInfo info, org.activemq.filter.Filter filter, org.activemq.service.RedeliveryPolicy redeliveryPolicy, org.activemq.service.DeadLetterPolicy deadLetterPolicy)

 

Method Summary
java.lang.String	getPersistentKey()           Returns the persistent key used to uniquely identify this durable topic subscription
void	messageConsumed(org.activemq.message.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

 

Field Detail

log

private static final org.apache.commons.logging.Log log

---

persistentKey

private java.lang.String persistentKey

Constructor Detail

DurableTopicSubscription

public DurableTopicSubscription(org.activemq.service.Dispatcher dispatcher,
                                org.activemq.broker.BrokerClient client,
                                org.activemq.message.ConsumerInfo info,
                                org.activemq.filter.Filter filter,
                                org.activemq.service.RedeliveryPolicy redeliveryPolicy,
                                org.activemq.service.DeadLetterPolicy deadLetterPolicy)

Method Detail

messageConsumed

public void messageConsumed(org.activemq.message.MessageAck ack)
                     throws javax.jms.JMSException

Description copied from class: SubscriptionImpl

Indicates a message has been delivered to a MessageConsumer

Specified by:

messageConsumed in interface org.activemq.service.Subscription

Overrides:

messageConsumed in class SubscriptionImpl

---

getPersistentKey

public java.lang.String getPersistentKey()

Description copied from interface: org.activemq.service.Subscription

Returns the persistent key used to uniquely identify this durable topic subscription

Specified by:

getPersistentKey in interface org.activemq.service.Subscription

Overrides:

getPersistentKey in class SubscriptionImpl

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> service >> [ impl overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---