public interface SubscriptionRecoveryPolicy extends Service
Modifier and Type | Method and Description |
---|---|
boolean |
add(ConnectionContext context,
MessageReference message)
A message was sent to the destination.
|
Message[] |
browse(ActiveMQDestination dest) |
SubscriptionRecoveryPolicy |
copy()
Used to copy the policy object.
|
void |
recover(ConnectionContext context,
Topic topic,
SubscriptionRecovery sub)
Let a subscription recover message held by the policy.
|
void |
setBroker(Broker broker) |
boolean add(ConnectionContext context, MessageReference message) throws java.lang.Exception
context
- message
- node
- java.lang.Exception
void recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub) throws java.lang.Exception
context
- topic
- sub
- node
- java.lang.Exception
Message[] browse(ActiveMQDestination dest) throws java.lang.Exception
dest
- java.lang.Exception
SubscriptionRecoveryPolicy copy()
Copyright © 2005-2012. All Rights Reserved.