org.apache.activemq.broker.region.policy
Class IndividualDeadLetterStrategy

java.lang.Object
  extended by org.apache.activemq.broker.region.policy.IndividualDeadLetterStrategy
All Implemented Interfaces:
DeadLetterStrategy

public class IndividualDeadLetterStrategy
extends java.lang.Object
implements DeadLetterStrategy

A DeadLetterStrategy where each destination has its own individual DLQ using the subject naming hierarchy.

Version:
$Revision: 426366 $

Constructor Summary
IndividualDeadLetterStrategy()
           
 
Method Summary
protected  ActiveMQDestination createDestination(ActiveMQDestination originalDestination, java.lang.String prefix, boolean useQueue)
           
 ActiveMQDestination getDeadLetterQueueFor(ActiveMQDestination originalDestination)
          Returns the dead letter queue for the given destination.
 java.lang.String getQueuePrefix()
           
 java.lang.String getTopicPrefix()
           
 boolean isUseQueueForQueueMessages()
           
 boolean isUseQueueForTopicMessages()
           
 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.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

IndividualDeadLetterStrategy

public IndividualDeadLetterStrategy()
Method Detail

getDeadLetterQueueFor

public ActiveMQDestination getDeadLetterQueueFor(ActiveMQDestination originalDestination)
Description copied from interface: DeadLetterStrategy
Returns the dead letter queue for the given destination.

Specified by:
getDeadLetterQueueFor in interface DeadLetterStrategy

getQueuePrefix

public java.lang.String getQueuePrefix()

setQueuePrefix

public void setQueuePrefix(java.lang.String queuePrefix)
Sets the prefix to use for all dead letter queues for queue messages


getTopicPrefix

public java.lang.String getTopicPrefix()

setTopicPrefix

public void setTopicPrefix(java.lang.String topicPrefix)
Sets the prefix to use for all dead letter queues for topic messages


isUseQueueForQueueMessages

public boolean isUseQueueForQueueMessages()

setUseQueueForQueueMessages

public void setUseQueueForQueueMessages(boolean useQueueForQueueMessages)
Sets whether a queue or topic should be used for queue messages sent to a DLQ. The default is to use a Queue


isUseQueueForTopicMessages

public boolean isUseQueueForTopicMessages()

setUseQueueForTopicMessages

public void setUseQueueForTopicMessages(boolean useQueueForTopicMessages)
Sets whether a queue or topic should be used for topic messages sent to a DLQ. The default is to use a Queue


createDestination

protected ActiveMQDestination createDestination(ActiveMQDestination originalDestination,
                                                java.lang.String prefix,
                                                boolean useQueue)


Copyright © 2009 Apache Software Foundation. All Rights Reserved.