org.apache.activemq.broker.region.policy

Class SharedDeadLetterStrategy

java.lang.Object

org.apache.activemq.broker.region.policy.AbstractDeadLetterStrategy

org.apache.activemq.broker.region.policy.SharedDeadLetterStrategy

All Implemented Interfaces:

DeadLetterStrategy

Direct Known Subclasses:

DiscardingDeadLetterStrategy

public class SharedDeadLetterStrategy
extends AbstractDeadLetterStrategy

A default implementation of DeadLetterStrategy which uses a constant destination.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_DEAD_LETTER_QUEUE_NAME

Constructor Summary

Constructors

Constructor and Description
SharedDeadLetterStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
ActiveMQDestination	getDeadLetterQueue()
ActiveMQDestination	getDeadLetterQueueFor(Message message, Subscription subscription) Returns the dead letter queue for the given message and subscription.
boolean	isDLQ(ActiveMQDestination destination)
void	setDeadLetterQueue(ActiveMQDestination deadLetterQueue)

Methods inherited from class org.apache.activemq.broker.region.policy.AbstractDeadLetterStrategy

isEnableAudit, isProcessExpired, isProcessNonPersistent, isSendToDeadLetterQueue, rollback, setEnableAudit, setProcessExpired, setProcessNonPersistent

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_DEAD_LETTER_QUEUE_NAME

public static final java.lang.String DEFAULT_DEAD_LETTER_QUEUE_NAME

See Also:

Constant Field Values

Constructor Detail

SharedDeadLetterStrategy

public SharedDeadLetterStrategy()

Method Detail

getDeadLetterQueueFor

public ActiveMQDestination getDeadLetterQueueFor(Message message,
                                        Subscription subscription)

Description copied from interface: DeadLetterStrategy

Returns the dead letter queue for the given message and subscription.

getDeadLetterQueue

public ActiveMQDestination getDeadLetterQueue()

setDeadLetterQueue

public void setDeadLetterQueue(ActiveMQDestination deadLetterQueue)

isDLQ

public boolean isDLQ(ActiveMQDestination destination)