Uses of Class
org.acemq.amqp.api.RetryPolicy

Packages that use RetryPolicy

Package	Description
org.acemq.amqp.api	The public AceMQ AMQP API.
org.acemq.amqp.core	The protocol-agnostic engine.

Uses of RetryPolicy in org.acemq.amqp.api

Methods in org.acemq.amqp.api that return RetryPolicy

Modifier and Type	Method	Description
static RetryPolicy	RetryPolicy.exponential(int maxAttempts, Duration initialDelay, double multiplier, Duration maxDelay)	Retries with an exponentially growing delay and an explicit multiplier.
static RetryPolicy	RetryPolicy.exponential(int maxAttempts, Duration initialDelay, Duration maxDelay)	Retries with a doubling delay, capped.
static RetryPolicy	RetryPolicy.fixed(int maxAttempts, Duration delay)	Retries a fixed number of times with the same delay between each, with no jitter.
RetryPolicy	RetryPolicy.giveUpAfter(Duration maxMessageAge)	Returns a copy that abandons messages older than the given age.
static RetryPolicy	RetryPolicy.none()	A policy that never retries: one attempt, then the dead-letter queue.
RetryPolicy	RetryPolicy.waitInBrokerFrom(Duration threshold)	Returns a copy that moves the line between waiting here and waiting there.
RetryPolicy	RetryPolicy.withJitter(double jitterFactor)	Returns a copy with a different amount of randomness applied to each delay.

Uses of RetryPolicy in org.acemq.amqp.core

Methods in org.acemq.amqp.core that return types with arguments of type RetryPolicy

Modifier and Type	Method	Description
Optional<RetryPolicy>	ConsumerOptions.retryPolicy()

Methods in org.acemq.amqp.core with parameters of type RetryPolicy

Modifier and Type	Method	Description
ConsumerOptions	ConsumerOptions.withRetry(RetryPolicy retryPolicy)	Retries failures on a schedule, never in a sleeping handler.
PipelineBuilder<T,C>	PipelineBuilder.withRetry(RetryPolicy policy)	Retries the most recently declared step on a schedule, never in a sleeping handler: the engine holds a short wait and the broker's queues hold a long one.