Package org.springframework.kafka.listener

Class DefaultBackOffHandler

java.lang.Object

org.springframework.kafka.listener.DefaultBackOffHandler

All Implemented Interfaces:

BackOffHandler

public class DefaultBackOffHandler
extends Object
implements BackOffHandler

Default BackOffHandler; suspends the thread for the back off. If a container is provided, ListenerUtils.stoppableSleep(MessageListenerContainer, long) is used, to terminate the suspension if the container is stopped.

Since:

2.9

Author:

Jan Marincek, Gary Russell

Constructor Summary

Constructors

Constructor	Description
DefaultBackOffHandler()

Method Summary

Modifier and Type	Method	Description
void	onNextBackOff(MessageListenerContainer container, Exception exception, long nextBackOff)	Perform the next back off.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.kafka.listener.BackOffHandler

onNextBackOff

Constructor Details

DefaultBackOffHandler

public DefaultBackOffHandler()

Method Details

onNextBackOff

public void onNextBackOff(@Nullable
 MessageListenerContainer container,
 Exception exception,
 long nextBackOff)

Description copied from interface: BackOffHandler

Perform the next back off.

Specified by:

onNextBackOff in interface BackOffHandler

Parameters:

container - the container.

exception - the exception.

nextBackOff - the next back off.