Class DefaultBackOffHandler
java.lang.Object
org.springframework.kafka.listener.DefaultBackOffHandler
- All Implemented Interfaces:
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
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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 interfaceBackOffHandler
- Parameters:
container
- the container.exception
- the exception.nextBackOff
- the next back off.
-