|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy
public class FixedCountSubscriptionRecoveryPolicy
This implementation of SubscriptionRecoveryPolicy
will keep a fixed count
of last messages.
Constructor Summary | |
---|---|
FixedCountSubscriptionRecoveryPolicy()
|
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. |
int |
getMaximumSize()
|
void |
recover(ConnectionContext context,
Topic topic,
Subscription sub)
Let a subscription recover message held by the policy. |
void |
setMaximumSize(int maximumSize)
Sets the maximum number of messages that this destination will hold around in RAM |
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 FixedCountSubscriptionRecoveryPolicy()
Method Detail |
---|
public SubscriptionRecoveryPolicy copy()
SubscriptionRecoveryPolicy
copy
in interface SubscriptionRecoveryPolicy
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, 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 int getMaximumSize()
public void setMaximumSize(int maximumSize)
public Message[] browse(ActiveMQDestination destination) throws java.lang.Exception
browse
in interface SubscriptionRecoveryPolicy
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |