Class TimedSubscriptionRecoveryPolicy
- java.lang.Object
-
- org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy
-
- All Implemented Interfaces:
SubscriptionRecoveryPolicy
,Service
public class TimedSubscriptionRecoveryPolicy extends Object implements SubscriptionRecoveryPolicy
This implementation ofSubscriptionRecoveryPolicy
will keep a timed buffer of messages around in memory and use that to recover new subscriptions.
-
-
Constructor Summary
Constructors Constructor Description TimedSubscriptionRecoveryPolicy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
add(ConnectionContext context, MessageReference message)
A message was sent to the destination.Message[]
browse(ActiveMQDestination destination)
SubscriptionRecoveryPolicy
copy()
Used to copy the policy object.void
gc()
long
getRecoverDuration()
void
recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub)
Let a subscription recover message held by the policy.void
setBroker(Broker broker)
void
setRecoverDuration(long recoverDuration)
void
start()
void
stop()
-
-
-
Method Detail
-
copy
public SubscriptionRecoveryPolicy copy()
Description copied from interface:SubscriptionRecoveryPolicy
Used to copy the policy object.- Specified by:
copy
in interfaceSubscriptionRecoveryPolicy
- Returns:
- the copy
-
add
public boolean add(ConnectionContext context, MessageReference message) throws Exception
Description copied from interface:SubscriptionRecoveryPolicy
A message was sent to the destination.- Specified by:
add
in interfaceSubscriptionRecoveryPolicy
- Returns:
- true if successful
- Throws:
Exception
-
recover
public void recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub) throws Exception
Description copied from interface:SubscriptionRecoveryPolicy
Let a subscription recover message held by the policy.- Specified by:
recover
in interfaceSubscriptionRecoveryPolicy
- Throws:
Exception
-
setBroker
public void setBroker(Broker broker)
- Specified by:
setBroker
in interfaceSubscriptionRecoveryPolicy
-
start
public void start() throws Exception
-
gc
public void gc()
-
getRecoverDuration
public long getRecoverDuration()
-
setRecoverDuration
public void setRecoverDuration(long recoverDuration)
-
browse
public Message[] browse(ActiveMQDestination destination) throws Exception
- Specified by:
browse
in interfaceSubscriptionRecoveryPolicy
- Returns:
- messages
- Throws:
Exception
-
-