|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
public class QueryBasedSubscriptionRecoveryPolicy
This implementation of SubscriptionRecoveryPolicy
will perform a user
specific query mechanism to load any messages they may have missed.
Constructor Summary | |
---|---|
QueryBasedSubscriptionRecoveryPolicy()
|
Method Summary | |
---|---|
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,
MessageEvaluationContext msgContext,
Subscription sub)
|
MessageQuery |
getQuery()
|
void |
recover(ConnectionContext context,
Topic topic,
Subscription sub)
Let a subscription recover message held by the policy. |
void |
setQuery(MessageQuery query)
Sets the query strategy to load initial messages |
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public QueryBasedSubscriptionRecoveryPolicy()
Method Detail |
---|
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, Subscription sub) throws java.lang.Exception
SubscriptionRecoveryPolicy
recover
in interface SubscriptionRecoveryPolicy
java.lang.Exception
public void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
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
protected void dispatchInitialMessage(javax.jms.Message message, Destination regionDestination, MessageEvaluationContext msgContext, Subscription sub)
protected void configure(ActiveMQMessage msg)
protected ProducerId createProducerId()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |