Class ConditionalDelegatingErrorHandler
- java.lang.Object
-
- org.springframework.kafka.listener.ConditionalDelegatingErrorHandler
-
- All Implemented Interfaces:
ConsumerAwareErrorHandler,ContainerAwareErrorHandler,ErrorHandler,GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>,RemainingRecordsErrorHandler
@Deprecated public class ConditionalDelegatingErrorHandler extends java.lang.Object implements ContainerAwareErrorHandler
Deprecated.in favor ofCommonDelegatingErrorHandler.An error handler that delegates to different error handlers, depending on the exception type.- Since:
- 2.7.4
- Author:
- Gary Russell
-
-
Constructor Summary
Constructors Constructor Description ConditionalDelegatingErrorHandler(ContainerAwareErrorHandler defaultErrorHandler)Deprecated.Construct an instance with a default error handler that will be invoked if the exception has no matches.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidaddDelegate(java.lang.Class<? extends java.lang.Throwable> throwable, ContainerAwareErrorHandler handler)Deprecated.Add a delegate to the end of the current collection.voidhandle(java.lang.Exception thrownException, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)Deprecated.Handle the exception.voidsetErrorHandlers(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,ContainerAwareErrorHandler> delegates)Deprecated.Set the delegate error handlers; aLinkedHashMapargument is recommended so that the delegates are searched in a known order.-
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.ConsumerAwareErrorHandler
handle
-
Methods inherited from interface org.springframework.kafka.listener.ContainerAwareErrorHandler
handle
-
Methods inherited from interface org.springframework.kafka.listener.GenericErrorHandler
clearThreadState, isAckAfterHandle, setAckAfterHandle
-
Methods inherited from interface org.springframework.kafka.listener.RemainingRecordsErrorHandler
handle
-
-
-
-
Constructor Detail
-
ConditionalDelegatingErrorHandler
public ConditionalDelegatingErrorHandler(ContainerAwareErrorHandler defaultErrorHandler)
Deprecated.Construct an instance with a default error handler that will be invoked if the exception has no matches.- Parameters:
defaultErrorHandler- the default error handler.
-
-
Method Detail
-
setErrorHandlers
public void setErrorHandlers(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,ContainerAwareErrorHandler> delegates)
Deprecated.Set the delegate error handlers; aLinkedHashMapargument is recommended so that the delegates are searched in a known order.- Parameters:
delegates- the delegates.
-
addDelegate
public void addDelegate(java.lang.Class<? extends java.lang.Throwable> throwable, ContainerAwareErrorHandler handler)Deprecated.Add a delegate to the end of the current collection.- Parameters:
throwable- the throwable for this handler.handler- the handler.
-
handle
public void handle(java.lang.Exception thrownException, @Nullable java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)Deprecated.Description copied from interface:ErrorHandlerHandle the exception.- Specified by:
handlein interfaceConsumerAwareErrorHandler- Specified by:
handlein interfaceContainerAwareErrorHandler- Specified by:
handlein interfaceErrorHandler- Specified by:
handlein interfaceRemainingRecordsErrorHandler- Parameters:
thrownException- the exception.records- the remaining records including the one that failed.consumer- the consumer.container- the container.
-
-