org.apache.activemq.broker.region
Interface SubscriptionRecovery
- All Known Subinterfaces:
- Subscription
- All Known Implementing Classes:
- AbstractSubscription, DurableTopicSubscription, PrefetchSubscription, QueueBrowserSubscription, QueueSubscription, TopicSubscription
public interface SubscriptionRecovery
An interface for recoverying transient messages held by the broker for
retractive recovery for subscribers
addRecoveredMessage
boolean addRecoveredMessage(ConnectionContext context,
MessageReference message)
throws java.lang.Exception
- Add a message to the SubscriptionRecovery
- Parameters:
context
- message
-
- Returns:
- true if the message is accepted
- Throws:
java.lang.Exception
getActiveMQDestination
ActiveMQDestination getActiveMQDestination()
- Returns:
- the Destination associated with this Subscription
Copyright © 2005-2016. All Rights Reserved.