Class 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
    • Constructor Detail

      • RedeliveryPlugin

        public RedeliveryPlugin()
    • Method Detail

      • 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 -