Class DefaultBackOffHandler
- java.lang.Object
-
- org.springframework.kafka.listener.DefaultBackOffHandler
-
- All Implemented Interfaces:
BackOffHandler
public class DefaultBackOffHandler extends java.lang.Object implements BackOffHandler
DefaultBackOffHandler; 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidonNextBackOff(MessageListenerContainer container, java.lang.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
-
-
-
-
Method Detail
-
onNextBackOff
public void onNextBackOff(@Nullable MessageListenerContainer container, java.lang.Exception exception, long nextBackOff)Description copied from interface:BackOffHandlerPerform the next back off.- Specified by:
onNextBackOffin interfaceBackOffHandler- Parameters:
container- the container.exception- the exception.nextBackOff- the next back off.
-
-