public class FixedCountSubscriptionRecoveryPolicy extends Object implements SubscriptionRecoveryPolicy
SubscriptionRecoveryPolicy
will keep a fixed
count of last messages.Constructor and Description |
---|
FixedCountSubscriptionRecoveryPolicy() |
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.
|
int |
getMaximumSize() |
void |
recover(ConnectionContext context,
Topic topic,
SubscriptionRecovery sub)
Let a subscription recover message held by the policy.
|
void |
setBroker(Broker broker) |
void |
setMaximumSize(int maximumSize)
Sets the maximum number of messages that this destination will hold
around in RAM
|
void |
start() |
void |
stop() |
public FixedCountSubscriptionRecoveryPolicy()
public SubscriptionRecoveryPolicy copy()
SubscriptionRecoveryPolicy
copy
in interface SubscriptionRecoveryPolicy
public boolean add(ConnectionContext context, MessageReference node) throws Exception
SubscriptionRecoveryPolicy
add
in interface SubscriptionRecoveryPolicy
Exception
public void recover(ConnectionContext context, Topic topic, SubscriptionRecovery sub) throws Exception
SubscriptionRecoveryPolicy
recover
in interface SubscriptionRecoveryPolicy
Exception
public int getMaximumSize()
public void setMaximumSize(int maximumSize)
public Message[] browse(ActiveMQDestination destination) throws Exception
browse
in interface SubscriptionRecoveryPolicy
Exception
public void setBroker(Broker broker)
setBroker
in interface SubscriptionRecoveryPolicy
Copyright © 2005–2015. All rights reserved.