org.apache.activemq.broker.region.policy
public class QueryBasedSubscriptionRecoveryPolicy extends java.lang.Object implements SubscriptionRecoveryPolicy
SubscriptionRecoveryPolicy
will perform a user
specific query mechanism to load any messages they may have missed.Constructor and Description |
---|
QueryBasedSubscriptionRecoveryPolicy() |
Modifier and Type | Method and Description |
---|---|
boolean |
add(ConnectionContext context,
MessageReference message)
A message was sent to the destination.
|
Message[] |
browse(ActiveMQDestination dest) |
protected void |
configure(ActiveMQMessage msg) |
SubscriptionRecoveryPolicy |
copy()
Used to copy the policy object.
|
protected ProducerId |
createProducerId() |
protected void |
dispatchInitialMessage(javax.jms.Message message,
Destination regionDestination,
ConnectionContext context,
SubscriptionRecovery sub) |
MessageQuery |
getQuery() |
void |
recover(ConnectionContext context,
Topic topic,
SubscriptionRecovery sub)
Let a subscription recover message held by the policy.
|
void |
setBroker(Broker broker) |
void |
setQuery(MessageQuery query)
Sets the query strategy to load initial messages
|
void |
start() |
void |
stop() |
public QueryBasedSubscriptionRecoveryPolicy()
public SubscriptionRecoveryPolicy copy()
SubscriptionRecoveryPolicy
copy
in interface SubscriptionRecoveryPolicy
public boolean add(ConnectionContext context, MessageReference message) throws java.lang.Exception
SubscriptionRecoveryPolicy
add
in interface SubscriptionRecoveryPolicy
java.lang.Exception
public void recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub) throws java.lang.Exception
SubscriptionRecoveryPolicy
recover
in interface SubscriptionRecoveryPolicy
java.lang.Exception
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public MessageQuery getQuery()
public void setQuery(MessageQuery query)
public Message[] browse(ActiveMQDestination dest) throws java.lang.Exception
browse
in interface SubscriptionRecoveryPolicy
java.lang.Exception
public void setBroker(Broker broker)
setBroker
in interface SubscriptionRecoveryPolicy
protected void dispatchInitialMessage(javax.jms.Message message, Destination regionDestination, ConnectionContext context, SubscriptionRecovery sub)
protected void configure(ActiveMQMessage msg) throws javax.jms.JMSException
javax.jms.JMSException
protected ProducerId createProducerId()
Copyright © 2005-2014. All Rights Reserved.