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

All Implemented Interfaces:
    SubscriptionRecoveryPolicy

This implementation of SubscriptionRecoveryPolicy will perform a user specific query mechanism to load any messages they may have missed.
Method from org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy 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 org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy 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