public class RedeliveryPlugin extends BrokerPluginSupport
Modifier and Type | Field and Description |
---|---|
static String |
REDELIVERY_DELAY |
next
Constructor and Description |
---|
RedeliveryPlugin() |
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,
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.
|
start, stop
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, 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, virtualDestinationAdded, virtualDestinationRemoved
public static final String REDELIVERY_DELAY
public RedeliveryPlugin()
public Broker installPlugin(Broker broker) throws Exception
BrokerPlugin
installPlugin
in interface BrokerPlugin
installPlugin
in class BrokerPluginSupport
Exception
public RedeliveryPolicyMap getRedeliveryPolicyMap()
public void setRedeliveryPolicyMap(RedeliveryPolicyMap redeliveryPolicyMap)
public boolean isSendToDlqIfMaxRetriesExceeded()
public void setSendToDlqIfMaxRetriesExceeded(boolean sendToDlqIfMaxRetriesExceeded)
sendToDlqIfMaxRetriesExceeded
- public boolean isFallbackToDeadLetter()
public void setFallbackToDeadLetter(boolean fallbackToDeadLetter)
fallbackToDeadLetter
- public boolean sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription, Throwable poisonCause)
Broker
sendToDeadLetterQueue
in interface Broker
sendToDeadLetterQueue
in class MutableBrokerFilter
poisonCause
- reason for dlq submission, may be nullCopyright © 2005–2016 The Apache Software Foundation. All rights reserved.