Package org.acemq.amqp.api

Class RetryPolicy.Wait

java.lang.Object
org.acemq.amqp.api.RetryPolicy.Wait
Enclosing class:
RetryPolicy
public static final class RetryPolicy.Wait extends Object
How long before the next attempt, and where the message spends it.

Two answers rather than one because they cannot be worked out separately: jitter applies only to a wait spent in the consumer, so a caller handed a delay on its own could not tell whether it had already been moved — and a moved delay does not name a rung queue.

  • Method Details

    • delay

      public Duration delay()
      Returns:
      how long the message waits

    • isInBroker

      public boolean isInBroker()
      Returns:
      whether it waits on a rung queue rather than in the consumer

    • toString

      public String toString()
      Overrides:
      toString in class Object