|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy
public class LastImageSubscriptionRecoveryPolicy
This implementation of SubscriptionRecoveryPolicy
will only keep
the last message.
Constructor Summary | |
---|---|
LastImageSubscriptionRecoveryPolicy()
|
Method Summary | |
---|---|
boolean |
add(ConnectionContext context,
MessageReference node)
A message was sent to the destination. |
Message[] |
browse(ActiveMQDestination destination)
|
SubscriptionRecoveryPolicy |
copy()
Used to copy the policy object. |
void |
recover(ConnectionContext context,
Topic topic,
Subscription sub)
Let a subscription recover message held by the policy. |
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 LastImageSubscriptionRecoveryPolicy()
Method Detail |
---|
public boolean add(ConnectionContext context, MessageReference node) throws Exception
SubscriptionRecoveryPolicy
add
in interface SubscriptionRecoveryPolicy
Exception
public void recover(ConnectionContext context, Topic topic, Subscription sub) throws Exception
SubscriptionRecoveryPolicy
recover
in interface SubscriptionRecoveryPolicy
Exception
public void start() throws Exception
start
in interface Service
Exception
public void stop() throws Exception
stop
in interface Service
Exception
public Message[] browse(ActiveMQDestination destination) throws Exception
browse
in interface SubscriptionRecoveryPolicy
Exception
public SubscriptionRecoveryPolicy copy()
SubscriptionRecoveryPolicy
copy
in interface SubscriptionRecoveryPolicy
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |