Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ service overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.service
Class DeadLetterPolicy  

java.lang.Object
  org.activemq.service.DeadLetterPolicy

---

public class DeadLetterPolicy

extends java.lang.Object

Determines how messages are stored in a dead letter queue

Version:

$Revision: 1.1.1.1 $

---

Field Summary
private  boolean	allowDuplicates
private  org.activemq.broker.Broker	broker
static java.lang.String	DEAD_LETTER_PREFIX           Prefix used by dead letter queues
private  boolean	deadLetterEnabled
private  java.lang.String	deadLetterName
private  boolean	deadLetterPerDestinationName
private  java.lang.String	deadLetterPrefix
private  long	deadLetterQueueTTL
private  long	deadLetterTopicTTL
private static java.lang.String	DEFAULT_DEAD_LETTER_NAME
private  org.activemq.util.IdGenerator	idGenerator
private static org.apache.commons.logging.Log	log
private  boolean	noTopicConsumerEnabled
private  boolean	storeNonPersistentMessages
private  boolean	useDatabaseLocking

 

Constructor Summary

DeadLetterPolicy()           Default constructor

DeadLetterPolicy(org.activemq.broker.Broker broker)           Construct a dead letter policy

DeadLetterPolicy(org.activemq.broker.BrokerContainer brokerContainer)

 

Method Summary
protected  org.activemq.message.ActiveMQMessage	createDeadLetterMessage(java.lang.String dlqName, org.activemq.message.ActiveMQMessage message)
org.activemq.broker.Broker	getBroker()
java.lang.String	getDeadLetterName()
java.lang.String	getDeadLetterNameFromDestination(org.activemq.message.ActiveMQDestination destination)           Get the name of the DLQ from the destination provided
java.lang.String	getDeadLetterPrefix()
boolean	isAllowDuplicates()
boolean	isDeadLetterEnabled()
boolean	isDeadLetterPerDestinationName()
boolean	isNoTopicConsumerEnabled()
boolean	isStoreNonPersistentMessages()
boolean	isUseDatabaseLocking()
void	sendToDeadLetter(org.activemq.message.ActiveMQMessage message)           Send a message to a dead letter queue
void	setAllowDuplicates(boolean allowDuplicates)
void	setBroker(org.activemq.broker.Broker broker)
void	setDeadLetterEnabled(boolean deadLetterEnabled)
void	setDeadLetterName(java.lang.String deadLetterName)
void	setDeadLetterPerDestinationName(boolean deadLetterPerDestinationName)
void	setDeadLetterPrefix(java.lang.String deadLetterPrefix)
void	setDeadLetterQueueTTL(long deadLetterQueueTTL)
void	setDeadLetterTopicTTL(long deadLetterTopicTTL)
void	setNoTopicConsumerEnabled(boolean noTopicConsumerEnabled)
void	setStoreNonPersistentMessages(boolean storeNonPersistentMessages)
void	setUseDatabaseLocking(boolean useDatabaseLocking)

 

Methods inherited from class java.lang.Object

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

 

Field Detail

DEAD_LETTER_PREFIX

public static final java.lang.String DEAD_LETTER_PREFIX

Prefix used by dead letter queues

See Also:

Constant Field Values

---

DEFAULT_DEAD_LETTER_NAME

private static final java.lang.String DEFAULT_DEAD_LETTER_NAME

See Also:

Constant Field Values

---

log

private static final org.apache.commons.logging.Log log

---

broker

private org.activemq.broker.Broker broker

---

deadLetterPrefix

private java.lang.String deadLetterPrefix

---

deadLetterName

private java.lang.String deadLetterName

---

deadLetterEnabled

private boolean deadLetterEnabled

---

deadLetterPerDestinationName

private boolean deadLetterPerDestinationName

---

storeNonPersistentMessages

private boolean storeNonPersistentMessages

---

noTopicConsumerEnabled

private boolean noTopicConsumerEnabled

---

allowDuplicates

private boolean allowDuplicates

---

useDatabaseLocking

private boolean useDatabaseLocking

---

deadLetterQueueTTL

private long deadLetterQueueTTL

---

deadLetterTopicTTL

private long deadLetterTopicTTL

---

idGenerator

private org.activemq.util.IdGenerator idGenerator

Constructor Detail

DeadLetterPolicy

public DeadLetterPolicy(org.activemq.broker.Broker broker)

Construct a dead letter policy

---

DeadLetterPolicy

public DeadLetterPolicy(org.activemq.broker.BrokerContainer brokerContainer)

---

DeadLetterPolicy

public DeadLetterPolicy()

Default constructor

Method Detail

getBroker

public org.activemq.broker.Broker getBroker()

---

setBroker

public void setBroker(org.activemq.broker.Broker broker)

---

isDeadLetterEnabled

public boolean isDeadLetterEnabled()

---

setDeadLetterEnabled

public void setDeadLetterEnabled(boolean deadLetterEnabled)

---

isDeadLetterPerDestinationName

public boolean isDeadLetterPerDestinationName()

---

setDeadLetterPerDestinationName

public void setDeadLetterPerDestinationName(boolean deadLetterPerDestinationName)

---

getDeadLetterName

public java.lang.String getDeadLetterName()

---

setDeadLetterName

public void setDeadLetterName(java.lang.String deadLetterName)

---

getDeadLetterPrefix

public java.lang.String getDeadLetterPrefix()

---

setDeadLetterPrefix

public void setDeadLetterPrefix(java.lang.String deadLetterPrefix)

---

isStoreNonPersistentMessages

public boolean isStoreNonPersistentMessages()

---

setStoreNonPersistentMessages

public void setStoreNonPersistentMessages(boolean storeNonPersistentMessages)

---

isNoTopicConsumerEnabled

public boolean isNoTopicConsumerEnabled()

---

setNoTopicConsumerEnabled

public void setNoTopicConsumerEnabled(boolean noTopicConsumerEnabled)

---

isAllowDuplicates

public boolean isAllowDuplicates()

---

setAllowDuplicates

public void setAllowDuplicates(boolean allowDuplicates)

---

isUseDatabaseLocking

public boolean isUseDatabaseLocking()

---

setUseDatabaseLocking

public void setUseDatabaseLocking(boolean useDatabaseLocking)

---

setDeadLetterQueueTTL

public void setDeadLetterQueueTTL(long deadLetterQueueTTL)

---

setDeadLetterTopicTTL

public void setDeadLetterTopicTTL(long deadLetterTopicTTL)

---

getDeadLetterNameFromDestination

public java.lang.String getDeadLetterNameFromDestination(org.activemq.message.ActiveMQDestination destination)

Get the name of the DLQ from the destination provided

---

sendToDeadLetter

public void sendToDeadLetter(org.activemq.message.ActiveMQMessage message)

Send a message to a dead letter queue

---

createDeadLetterMessage

protected org.activemq.message.ActiveMQMessage createDeadLetterMessage(java.lang.String dlqName,
                                                                       org.activemq.message.ActiveMQMessage message)
                                                                throws javax.jms.JMSException

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ service overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---