|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.policy.AbstractDeadLetterStrategy
org.apache.activemq.broker.region.policy.IndividualDeadLetterStrategy
public class IndividualDeadLetterStrategy
A DeadLetterStrategy
where each destination has its own individual
DLQ using the subject naming hierarchy.
Constructor Summary | |
---|---|
IndividualDeadLetterStrategy()
|
Method Summary | |
---|---|
protected ActiveMQDestination |
createDestination(ActiveMQDestination originalDestination,
String prefix,
boolean useQueue)
|
ActiveMQDestination |
getDeadLetterQueueFor(ActiveMQDestination originalDestination)
Returns the dead letter queue for the given destination. |
String |
getQueuePrefix()
|
String |
getTopicPrefix()
|
boolean |
isUseQueueForQueueMessages()
|
boolean |
isUseQueueForTopicMessages()
|
void |
setQueuePrefix(String queuePrefix)
Sets the prefix to use for all dead letter queues for queue messages |
void |
setTopicPrefix(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 org.apache.activemq.broker.region.policy.AbstractDeadLetterStrategy |
---|
isProcessExpired, isProcessNonPersistent, isSendToDeadLetterQueue, setProcessExpired, setProcessNonPersistent |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public IndividualDeadLetterStrategy()
Method Detail |
---|
public ActiveMQDestination getDeadLetterQueueFor(ActiveMQDestination originalDestination)
DeadLetterStrategy
public String getQueuePrefix()
public void setQueuePrefix(String queuePrefix)
public String getTopicPrefix()
public void setTopicPrefix(String topicPrefix)
public boolean isUseQueueForQueueMessages()
public void setUseQueueForQueueMessages(boolean useQueueForQueueMessages)
public boolean isUseQueueForTopicMessages()
public void setUseQueueForTopicMessages(boolean useQueueForTopicMessages)
protected ActiveMQDestination createDestination(ActiveMQDestination originalDestination, String prefix, boolean useQueue)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |