org.apache.activemq.broker.region.policy
public class IndividualDeadLetterStrategy extends AbstractDeadLetterStrategy
DeadLetterStrategy
where each destination has its own individual
DLQ using the subject naming hierarchy.Constructor and Description |
---|
IndividualDeadLetterStrategy() |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQDestination |
createDestination(Message message,
java.lang.String prefix,
boolean useQueue,
Subscription subscription) |
ActiveMQDestination |
getDeadLetterQueueFor(Message message,
Subscription subscription)
Returns the dead letter queue for the given message and subscription.
|
java.lang.String |
getQueuePrefix() |
java.lang.String |
getTopicPrefix() |
boolean |
isDestinationPerDurableSubscriber() |
boolean |
isUseQueueForQueueMessages() |
boolean |
isUseQueueForTopicMessages() |
void |
setDestinationPerDurableSubscriber(boolean destinationPerDurableSubscriber)
sets whether durable topic subscriptions are to get individual dead letter destinations.
|
void |
setQueuePrefix(java.lang.String queuePrefix)
Sets the prefix to use for all dead letter queues for queue messages
|
void |
setTopicPrefix(java.lang.String topicPrefix)
Sets the prefix to use for all dead letter queues for topic messages
|
void |
setUseQueueForQueueMessages(boolean useQueueForQueueMessages)
Sets whether a queue or topic should be used for queue messages sent to a
DLQ.
|
void |
setUseQueueForTopicMessages(boolean useQueueForTopicMessages)
Sets whether a queue or topic should be used for topic messages sent to a
DLQ.
|
isEnableAudit, isProcessExpired, isProcessNonPersistent, isSendToDeadLetterQueue, setEnableAudit, setProcessExpired, setProcessNonPersistent
public IndividualDeadLetterStrategy()
public ActiveMQDestination getDeadLetterQueueFor(Message message, Subscription subscription)
DeadLetterStrategy
public java.lang.String getQueuePrefix()
public void setQueuePrefix(java.lang.String queuePrefix)
public java.lang.String getTopicPrefix()
public void setTopicPrefix(java.lang.String topicPrefix)
public boolean isUseQueueForQueueMessages()
public void setUseQueueForQueueMessages(boolean useQueueForQueueMessages)
public boolean isUseQueueForTopicMessages()
public void setUseQueueForTopicMessages(boolean useQueueForTopicMessages)
public boolean isDestinationPerDurableSubscriber()
public void setDestinationPerDurableSubscriber(boolean destinationPerDurableSubscriber)
destinationPerDurableSubscriber
- protected ActiveMQDestination createDestination(Message message, java.lang.String prefix, boolean useQueue, Subscription subscription)
Copyright © 2005-2014. All Rights Reserved.