Uses of Interface
org.springframework.integration.core.RecoveryCallback
Packages that use RecoveryCallback
Package
Description
Provides AMQP Component support for the Java DSL.
Provides classes supporting inbound endpoints.
Provides classes that are used to advise
MessageHandlers with
cross-cutting concerns.Provides JMS Component support for the Java DSL.
Inbound channel adapters for JMS.
Provides Spring Integration Java DSL Components support for Apache Kafka.
Provides Spring Integration inbound components for Apache Kafka.
-
Uses of RecoveryCallback in org.springframework.integration.amqp.dsl
Methods in org.springframework.integration.amqp.dsl with parameters of type RecoveryCallbackModifier and TypeMethodDescriptionAmqpBaseInboundChannelAdapterSpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) Set aRecoveryCallbackwhen using retry within the adapter.AmqpBaseInboundGatewaySpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) Set aRecoveryCallbackwhen using retry within the adapter. -
Uses of RecoveryCallback in org.springframework.integration.amqp.inbound
Fields in org.springframework.integration.amqp.inbound declared as RecoveryCallbackModifier and TypeFieldDescriptionprotected final @Nullable RecoveryCallback<?> AmqpInboundChannelAdapter.Listener.recovererMethods in org.springframework.integration.amqp.inbound with parameters of type RecoveryCallbackModifier and TypeMethodDescriptionvoidAmqpInboundChannelAdapter.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) Set aRecoveryCallbackwhen using retry within the adapter.voidAmqpInboundGateway.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) Set aRecoveryCallbackwhen using retry within the gateway. -
Uses of RecoveryCallback in org.springframework.integration.handler.advice
Classes in org.springframework.integration.handler.advice that implement RecoveryCallbackModifier and TypeClassDescriptionclassARecoveryCallbackthat sends the final throwable as anErrorMessageafter retry exhaustion.Methods in org.springframework.integration.handler.advice with parameters of type RecoveryCallbackModifier and TypeMethodDescriptionvoidRequestHandlerRetryAdvice.setRecoveryCallback(RecoveryCallback<Object> recoveryCallback) Set aRecoveryCallbackto handle aRetryException. -
Uses of RecoveryCallback in org.springframework.integration.jms.dsl
Methods in org.springframework.integration.jms.dsl with parameters of type RecoveryCallbackModifier and TypeMethodDescriptionJmsInboundGatewaySpec.recoveryCallback(RecoveryCallback<Message<?>> recoveryCallback) Set aRecoveryCallbackwhen using retry within the adapter.JmsMessageDrivenChannelAdapterSpec.recoveryCallback(RecoveryCallback<Message<?>> recoveryCallback) Set aRecoveryCallbackwhen using retry within the adapter. -
Uses of RecoveryCallback in org.springframework.integration.jms.inbound
Methods in org.springframework.integration.jms.inbound with parameters of type RecoveryCallbackModifier and TypeMethodDescriptionvoidChannelPublishingJmsMessageListener.setRecoveryCallback(RecoveryCallback<Message<?>> recoveryCallback) Set aRecoveryCallbackwhen using retry within the adapter. -
Uses of RecoveryCallback in org.springframework.integration.kafka.dsl
Methods in org.springframework.integration.kafka.dsl with parameters of type RecoveryCallbackModifier and TypeMethodDescriptionKafkaInboundGatewaySpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) ARecoveryCallbackinstance for retry operation; if null, the exception will be thrown to the container after retries are exhausted.KafkaMessageDrivenChannelAdapterSpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) ARecoveryCallbackinstance for retry operation; if null, the exception will be thrown to the container after retries are exhausted. -
Uses of RecoveryCallback in org.springframework.integration.kafka.inbound
Methods in org.springframework.integration.kafka.inbound with parameters of type RecoveryCallbackModifier and TypeMethodDescriptiondefault voidKafkaInboundEndpoint.doWithRetry(RetryTemplate template, @Nullable RecoveryCallback<?> callback, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, @Nullable org.springframework.kafka.support.Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Runnable runnable) Execute the runnable with the retry template and recovery callback.voidKafkaInboundGateway.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) ARecoveryCallbackinstance for retry operation; if null, the exception will be thrown to the container after retries are exhausted (unless an error channel is configured).voidKafkaMessageDrivenChannelAdapter.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) ARecoveryCallbackinstance for retry operation; if null, the exception will be thrown to the container after retries are exhausted (unless an error channel is configured).