|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface SubscriptionRecoveryPolicy
Abstraction to allow different recovery policies to be plugged into the region implementations. This is used by a topic to retroactively recover messages that the subscription missed.
Method Summary | |
---|---|
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,
Subscription sub)
Let a subscription recover message held by the policy. |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
boolean add(ConnectionContext context, MessageReference message) throws java.lang.Exception
context
- message
- node
-
java.lang.Exception
void recover(ConnectionContext context, Topic topic, Subscription 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()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |