org.apache.activemq.broker.region.policy
public class LastImageSubscriptionRecoveryPolicy extends java.lang.Object implements SubscriptionRecoveryPolicy
SubscriptionRecoveryPolicy
will only keep the
last message.Constructor and Description |
---|
LastImageSubscriptionRecoveryPolicy() |
Modifier and Type | Method and Description |
---|---|
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,
SubscriptionRecovery sub)
Let a subscription recover message held by the policy.
|
void |
setBroker(Broker broker) |
void |
start() |
void |
stop() |
public LastImageSubscriptionRecoveryPolicy()
public boolean add(ConnectionContext context, MessageReference node) 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 Message[] browse(ActiveMQDestination destination) throws java.lang.Exception
browse
in interface SubscriptionRecoveryPolicy
java.lang.Exception
public SubscriptionRecoveryPolicy copy()
SubscriptionRecoveryPolicy
copy
in interface SubscriptionRecoveryPolicy
public void setBroker(Broker broker)
setBroker
in interface SubscriptionRecoveryPolicy
Copyright © 2005-2014. All Rights Reserved.