Package org.springframework.kafka.retrytopic

Class RetryTopicConfigurationSupport.BlockingRetriesConfigurer

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.BlockingRetriesConfigurer

Enclosing class:

RetryTopicConfigurationSupport

public static class RetryTopicConfigurationSupport.BlockingRetriesConfigurer
extends Object

Configure blocking retries to be used along non-blocking.

Constructor Summary

Constructors

Constructor	Description
BlockingRetriesConfigurer()

Method Summary

Modifier and Type	Method	Description
RetryTopicConfigurationSupport.BlockingRetriesConfigurer	backOff(BackOff backoff)	Set the BackOff that should be used with the blocking retry mechanism.
final RetryTopicConfigurationSupport.BlockingRetriesConfigurer	retryOn(Class<? extends Exception>... exceptions)	Set the exceptions that should be retried by the blocking retry mechanism.

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingRetriesConfigurer

public BlockingRetriesConfigurer()

Method Details

retryOn

@SafeVarargs
public final RetryTopicConfigurationSupport.BlockingRetriesConfigurer retryOn(Class<? extends Exception>... exceptions)

Set the exceptions that should be retried by the blocking retry mechanism.

Parameters:

exceptions - the exceptions.

Returns:

the configurer.

See Also:

• DefaultErrorHandler

backOff

public RetryTopicConfigurationSupport.BlockingRetriesConfigurer backOff(BackOff backoff)

Set the BackOff that should be used with the blocking retry mechanism. By default, a FixedBackOff with 0 delay and 9 retry attempts is configured. Note that this only has any effect for exceptions specified with the retryOn(java.lang.Class<? extends java.lang.Exception>...) method - by default blocking retries are disabled when using the non-blocking retries feature.

Parameters:

backoff - the BackOff instance.

Returns:

the configurer.

See Also:

• DefaultErrorHandler