Class AbstractDeadLetterStrategy

    • Constructor Detail

      • AbstractDeadLetterStrategy

        public AbstractDeadLetterStrategy()
    • Method Detail

      • rollback

        public void rollback​(Message message)
        Description copied from interface: DeadLetterStrategy
        Allows for a Message that was already processed by a DLQ to be rolled back in case of a move or a retry of that message, otherwise the Message would be considered a duplicate if this strategy is doing Message Auditing.
        Specified by:
        rollback in interface DeadLetterStrategy
      • isSendToDeadLetterQueue

        public boolean isSendToDeadLetterQueue​(Message message)
        Description copied from interface: DeadLetterStrategy
        Allow pluggable strategy for deciding if message should be sent to a dead letter queue for example, you might not want to ignore expired or non-persistent messages
        Specified by:
        isSendToDeadLetterQueue in interface DeadLetterStrategy
        true if message should be sent to a dead letter queue
      • setProcessExpired

        public void setProcessExpired​(boolean processExpired)
        Specified by:
        setProcessExpired in interface DeadLetterStrategy
        processExpired - the processExpired to set
      • setProcessNonPersistent

        public void setProcessNonPersistent​(boolean processNonPersistent)
        Specified by:
        setProcessNonPersistent in interface DeadLetterStrategy
        processNonPersistent - the processNonPersistent to set
      • isEnableAudit

        public boolean isEnableAudit()
      • setEnableAudit

        public void setEnableAudit​(boolean enableAudit)
      • setExpiration

        public void setExpiration​(long expiration)
        Description copied from interface: DeadLetterStrategy
        The expiration value to use on messages sent to the DLQ, default 0
        Specified by:
        setExpiration in interface DeadLetterStrategy
      • getMaxProducersToAudit

        public int getMaxProducersToAudit()
      • setMaxProducersToAudit

        public void setMaxProducersToAudit​(int maxProducersToAudit)
      • setMaxAuditDepth

        public void setMaxAuditDepth​(int maxAuditDepth)
      • getMaxAuditDepth

        public int getMaxAuditDepth()