org.springframework.amqp.rabbit.config

Class RetryInterceptorBuilder.StatefulRetryInterceptorBuilder

java.lang.Object

org.springframework.amqp.rabbit.config.RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder

Enclosing class:

RetryInterceptorBuilder<T extends org.aopalliance.intercept.MethodInterceptor>

public static final class RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
extends RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

Builder for a stateful interceptor.

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder

RetryInterceptorBuilder.StatefulRetryInterceptorBuilder, RetryInterceptorBuilder.StatelessRetryInterceptorBuilder

Method Summary

Modifier and Type	Method and Description
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	backOffOptions(long initialInterval, double multiplier, long maxInterval) Apply the backoff options.
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	backOffPolicy(org.springframework.retry.backoff.BackOffPolicy policy) Apply the back off policy.
org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor	build()
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	maxAttempts(int maxAttempts) Apply the max attempts - a SimpleRetryPolicy will be used.
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	messageKeyGenerator(MessageKeyGenerator messageKeyGenerator) Stateful retry requires messages to be identifiable.
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	newMessageIdentifier(NewMessageIdentifier newMessageIdentifier) Apply a custom new message identifier.
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	recoverer(MessageRecoverer recoverer) Apply a Message recoverer - default is to log and discard after retry is exhausted.
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	retryOperations(org.springframework.retry.RetryOperations retryOperations) Apply the retry operations - once this is set, other properties can no longer be set; can't be set if other properties have been applied.
RetryInterceptorBuilder.StatefulRetryInterceptorBuilder	retryPolicy(org.springframework.retry.RetryPolicy policy) Apply the retry policy - cannot be used if a custom retry template has been provided, or the max attempts or back off options or policy have been applied.

Methods inherited from class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder

applyCommonSettings, stateful, stateless

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

messageKeyGenerator

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder messageKeyGenerator(MessageKeyGenerator messageKeyGenerator)

Stateful retry requires messages to be identifiable. Default is to use the message id header; use a custom implementation if the message id is not present or not reliable.

Parameters:

messageKeyGenerator - The key generator.

Returns:

this.

newMessageIdentifier

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder newMessageIdentifier(NewMessageIdentifier newMessageIdentifier)

Apply a custom new message identifier. Default is to use the redelivered header.

Parameters:

newMessageIdentifier - The new message identifier.

Returns:

this.

retryOperations

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder retryOperations(org.springframework.retry.RetryOperations retryOperations)

Description copied from class: RetryInterceptorBuilder

Apply the retry operations - once this is set, other properties can no longer be set; can't be set if other properties have been applied.

Overrides:

retryOperations in class RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

Parameters:

retryOperations - The retry operations.

Returns:

this.

maxAttempts

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder maxAttempts(int maxAttempts)

Description copied from class: RetryInterceptorBuilder

Apply the max attempts - a SimpleRetryPolicy will be used. Cannot be used if a custom retry operations or retry policy has been set.

Overrides:

maxAttempts in class RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

Parameters:

maxAttempts - the max attempts.

Returns:

this.

backOffOptions

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder backOffOptions(long initialInterval,
                                                                              double multiplier,
                                                                              long maxInterval)

Description copied from class: RetryInterceptorBuilder

Apply the backoff options. Cannot be used if a custom retry operations, or back off policy has been set.

Overrides:

backOffOptions in class RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

Parameters:

initialInterval - The initial interval.

multiplier - The multiplier.

maxInterval - The max interval.

Returns:

this.

retryPolicy

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder retryPolicy(org.springframework.retry.RetryPolicy policy)

Description copied from class: RetryInterceptorBuilder

Apply the retry policy - cannot be used if a custom retry template has been provided, or the max attempts or back off options or policy have been applied.

Overrides:

retryPolicy in class RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

Parameters:

policy - The policy.

Returns:

this.

backOffPolicy

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder backOffPolicy(org.springframework.retry.backoff.BackOffPolicy policy)

Description copied from class: RetryInterceptorBuilder

Apply the back off policy. Cannot be used if a custom retry operations, or back off policy has been applied.

Overrides:

backOffPolicy in class RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

Parameters:

policy - The policy.

Returns:

this.

recoverer

public RetryInterceptorBuilder.StatefulRetryInterceptorBuilder recoverer(MessageRecoverer recoverer)

Description copied from class: RetryInterceptorBuilder

Apply a Message recoverer - default is to log and discard after retry is exhausted.

Overrides:

recoverer in class RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>

Parameters:

recoverer - The recoverer.

Returns:

this.

build

public org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor build()

Specified by:

build in class RetryInterceptorBuilder<org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor>