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

All Implemented Interfaces:

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 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 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