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 class: TimedSubscriptionRecoveryPolicy [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy

All Implemented Interfaces:
    SubscriptionRecoveryPolicy

This implementation of SubscriptionRecoveryPolicy will keep a timed buffer of messages around in memory and use that to recover new subscriptions.
Nested Class Summary:
static class  TimedSubscriptionRecoveryPolicy.TimestampWrapper   
Field Summary
protected static final  Scheduler scheduler     
Method from org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy Summary:
add,   browse,   copy,   gc,   getRecoverDuration,   recover,   setRecoverDuration,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy Detail:
 public boolean add(ConnectionContext context,
    MessageReference message) throws Exception 
 public Message[] browse(ActiveMQDestination destination) throws Exception 
 public SubscriptionRecoveryPolicy copy() 
 public  void gc() 
 public long getRecoverDuration() 
 public  void recover(ConnectionContext context,
    Topic topic,
    SubscriptionRecovery sub) throws Exception 
 public  void setRecoverDuration(long recoverDuration) 
 public  void start() throws Exception 
 public  void stop() throws Exception