org.apache.activemq.broker.util

Class RedeliveryPlugin

java.lang.Object

org.apache.activemq.broker.MutableBrokerFilter

org.apache.activemq.broker.BrokerPluginSupport

org.apache.activemq.broker.util.RedeliveryPlugin

All Implemented Interfaces:

Broker, BrokerPlugin, Region, Service

public class RedeliveryPlugin
extends BrokerPluginSupport

Replace regular DLQ handling with redelivery via a resend to the original destination after a delay A destination matching RedeliveryPolicy controls the quantity and delay for re-sends If there is no matching policy or an existing policy limit is exceeded by default regular DLQ processing resumes. This is controlled via sendToDlqIfMaxRetriesExceeded and fallbackToDeadLetter

Field Summary

Fields

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

Fields inherited from class org.apache.activemq.broker.MutableBrokerFilter

next

Constructor Summary

Constructors

Constructor and Description
RedeliveryPlugin()

Method Summary

Methods

Modifier and Type	Method and Description
RedeliveryPolicyMap	getRedeliveryPolicyMap()
Broker	installPlugin(Broker broker) Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.
boolean	isFallbackToDeadLetter()
boolean	isSendToDlqIfMaxRetriesExceeded()
boolean	sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, java.lang.Throwable poisonCause) A message needs to go the a DLQ
void	setFallbackToDeadLetter(boolean fallbackToDeadLetter) What to do if there is no matching redelivery policy for a destination.
void	setRedeliveryPolicyMap(RedeliveryPolicyMap redeliveryPolicyMap)
void	setSendToDlqIfMaxRetriesExceeded(boolean sendToDlqIfMaxRetriesExceeded) What to do if the maxretries on a matching redelivery policy is exceeded.

Methods inherited from class org.apache.activemq.broker.BrokerPluginSupport

start, stop

Methods inherited from class org.apache.activemq.broker.MutableBrokerFilter

acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getNext, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, setAdminConnectionContext, setNext, slowConsumer

Methods inherited from class java.lang.Object

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

Field Detail

REDELIVERY_DELAY

public static final java.lang.String REDELIVERY_DELAY

See Also:

Constant Field Values

Constructor Detail

RedeliveryPlugin

public RedeliveryPlugin()

Method Detail

installPlugin

public Broker installPlugin(Broker broker)
                     throws java.lang.Exception

Description copied from interface: BrokerPlugin

Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.

Specified by:

installPlugin in interface BrokerPlugin

Overrides:

installPlugin in class BrokerPluginSupport

Throws:

java.lang.Exception

getRedeliveryPolicyMap

public RedeliveryPolicyMap getRedeliveryPolicyMap()

setRedeliveryPolicyMap

public void setRedeliveryPolicyMap(RedeliveryPolicyMap redeliveryPolicyMap)

isSendToDlqIfMaxRetriesExceeded

public boolean isSendToDlqIfMaxRetriesExceeded()

setSendToDlqIfMaxRetriesExceeded

public void setSendToDlqIfMaxRetriesExceeded(boolean sendToDlqIfMaxRetriesExceeded)

What to do if the maxretries on a matching redelivery policy is exceeded. when true, the region broker DLQ processing will be used via sendToDeadLetterQueue when false, there is no action

Parameters:

sendToDlqIfMaxRetriesExceeded -

isFallbackToDeadLetter

public boolean isFallbackToDeadLetter()

setFallbackToDeadLetter

public void setFallbackToDeadLetter(boolean fallbackToDeadLetter)

What to do if there is no matching redelivery policy for a destination. when true, the region broker DLQ processing will be used via sendToDeadLetterQueue when false, there is no action

Parameters:

fallbackToDeadLetter -

sendToDeadLetterQueue

public boolean sendToDeadLetterQueue(ConnectionContext context,
                            MessageReference messageReference,
                            Subscription subscription,
                            java.lang.Throwable poisonCause)

Description copied from interface: Broker

A message needs to go the a DLQ

Specified by:

sendToDeadLetterQueue in interface Broker

Overrides:

sendToDeadLetterQueue in class MutableBrokerFilter

poisonCause - reason for dlq submission, may be null

Returns:

true if Message was placed in a DLQ false if discarded.