Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » policy » [javadoc | source]
org.apache.activemq.broker.region.policy
public interface: SubscriptionRecoveryPolicy [javadoc | source]

All Implemented Interfaces:
    Service

All Known Implementing Classes:
    FixedCountSubscriptionRecoveryPolicy, LastImageSubscriptionRecoveryPolicy, NoSubscriptionRecoveryPolicy, TimedSubscriptionRecoveryPolicy, FixedSizedSubscriptionRecoveryPolicy, QueryBasedSubscriptionRecoveryPolicy

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 from org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy Summary:
add,   browse,   copy,   recover
Method from org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy Detail:
 public boolean add(ConnectionContext context,
    MessageReference message) throws Exception
    A message was sent to the destination.
 public Message[] browse(ActiveMQDestination dest) throws Exception
 public SubscriptionRecoveryPolicy copy()
    Used to copy the policy object.
 public  void recover(ConnectionContext context,
    Topic topic,
    SubscriptionRecovery sub) throws Exception
    Let a subscription recover message held by the policy.