org.activemq.service.impl
Class DurableTopicSubscription
java.lang.Object
org.activemq.service.impl.SubscriptionImpl
org.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 $
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 |
DurableTopicSubscription
public DurableTopicSubscription(Dispatcher dispatcher,
BrokerClient client,
ConsumerInfo info,
Filter filter,
RedeliveryPolicy redeliveryPolicy,
DeadLetterPolicy deadLetterPolicy)
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.