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 Exception
context
- message
- Exception
void recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub) throws Exception
context
- topic
- sub
- Exception
Message[] browse(ActiveMQDestination dest) throws Exception
dest
- Exception
SubscriptionRecoveryPolicy copy()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.