public class RetainedMessageSubscriptionRecoveryPolicy extends Object implements SubscriptionRecoveryPolicy
SubscriptionRecoveryPolicy
will only keep the
last non-zero length message with the ActiveMQMessage
.RETAIN_PROPERTY.Modifier and Type | Field and Description |
---|---|
static String |
RETAIN_PROPERTY |
static String |
RETAINED_PROPERTY |
Constructor and Description |
---|
RetainedMessageSubscriptionRecoveryPolicy(SubscriptionRecoveryPolicy wrapped) |
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.
|
SubscriptionRecoveryPolicy |
getWrapped() |
void |
recover(ConnectionContext context,
Topic topic,
SubscriptionRecovery sub)
Let a subscription recover message held by the policy.
|
void |
setBroker(Broker broker) |
void |
setWrapped(SubscriptionRecoveryPolicy wrapped) |
void |
start() |
void |
stop() |
public static final String RETAIN_PROPERTY
public static final String RETAINED_PROPERTY
public RetainedMessageSubscriptionRecoveryPolicy(SubscriptionRecoveryPolicy wrapped)
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 Message[] browse(ActiveMQDestination destination) throws Exception
browse
in interface SubscriptionRecoveryPolicy
Exception
public SubscriptionRecoveryPolicy copy()
SubscriptionRecoveryPolicy
copy
in interface SubscriptionRecoveryPolicy
public void setBroker(Broker broker)
setBroker
in interface SubscriptionRecoveryPolicy
public void setWrapped(SubscriptionRecoveryPolicy wrapped)
public SubscriptionRecoveryPolicy getWrapped()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.