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