org.apache.activemq.broker.region.policy
Class TimedSubscriptionRecoveryPolicy

java.lang.Object
  org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy

All Implemented Interfaces:

SubscriptionRecoveryPolicy, Service

public class TimedSubscriptionRecoveryPolicy
extends java.lang.Object
implements SubscriptionRecoveryPolicy

This implementation of SubscriptionRecoveryPolicy will keep a timed buffer of messages around in memory and use that to recover new subscriptions.

Constructor Summary

TimedSubscriptionRecoveryPolicy()

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimedSubscriptionRecoveryPolicy

public TimedSubscriptionRecoveryPolicy()

Method Detail

copy

public SubscriptionRecoveryPolicy copy()

Description copied from interface: SubscriptionRecoveryPolicy

Used to copy the policy object.

Specified by:

copy in interface SubscriptionRecoveryPolicy

Returns:

the copy

add

public boolean add(ConnectionContext context,
                   MessageReference message)
            throws java.lang.Exception

Description copied from interface: SubscriptionRecoveryPolicy

A message was sent to the destination.

Specified by:

add in interface SubscriptionRecoveryPolicy

Returns:

true if successful

Throws:

java.lang.Exception

recover

public void recover(ConnectionContext context,
                    Topic topic,
                    SubscriptionRecovery sub)
             throws java.lang.Exception

Description copied from interface: SubscriptionRecoveryPolicy

Let a subscription recover message held by the policy.

Specified by:

recover in interface SubscriptionRecoveryPolicy

Throws:

java.lang.Exception

setBroker

public void setBroker(Broker broker)

Specified by:

setBroker in interface SubscriptionRecoveryPolicy

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface Service

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Specified by:

stop in interface Service

Throws:

java.lang.Exception

gc

public void gc()

getRecoverDuration

public long getRecoverDuration()

setRecoverDuration

public void setRecoverDuration(long recoverDuration)

browse

public Message[] browse(ActiveMQDestination destination)
                 throws java.lang.Exception

Specified by:

browse in interface SubscriptionRecoveryPolicy

Returns:

messages

Throws:

java.lang.Exception