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

All Implemented Interfaces:

This implementation of SubscriptionRecoveryPolicy will perform a user specific query mechanism to load any messages they may have missed.
Method from Summary:
add,   browse,   configure,   copy,   createProducerId,   dispatchInitialMessage,   getQuery,   recover,   setQuery,   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 dest) throws Exception 
 protected  void configure(ActiveMQMessage msg) throws JMSException 
 public SubscriptionRecoveryPolicy copy() 
 protected ProducerId createProducerId() 
 protected  void dispatchInitialMessage(Message message,
    Destination regionDestination,
    ConnectionContext context,
    SubscriptionRecovery sub) 
 public MessageQuery getQuery() 
 public  void recover(ConnectionContext context,
    Topic topic,
    SubscriptionRecovery sub) throws Exception 
 public  void setQuery(MessageQuery query) 
    Sets the query strategy to load initial messages
 public  void start() throws Exception 
 public  void stop() throws Exception