インターフェースの使用
org.springframework.integration.core.RecoveryCallback
RecoveryCallback を使用するパッケージ
パッケージ
説明
Java DSL の AMQP コンポーネントサポートを提供します。
受信エンドポイントをサポートするクラスを提供します。
MessageHandler に横断的な関心事をアドバイスするために使用されるクラスを提供します。Java DSL の JMS コンポーネントサポートを提供します。
JMS の受信チャネルアダプター。
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
Apache Kafka 用の Spring Integration 受信コンポーネントを提供します。
org.springframework.integration.amqp.dsl 内の RecoveryCallback 使用
型 RecoveryCallback のパラメーターを持つ org.springframework.integration.amqp.dsl のメソッド修飾子と型メソッド説明AmqpBaseInboundChannelAdapterSpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) アダプター内で再試行を使用する場合は、RecoveryCallbackを設定してください。AmqpBaseInboundGatewaySpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) アダプター内で再試行を使用する場合は、RecoveryCallbackを設定してください。org.springframework.integration.amqp.inbound 内の RecoveryCallback 使用
RecoveryCallback として宣言されている org.springframework.integration.amqp.inbound のフィールド修飾子と型フィールド説明protected final @Nullable RecoveryCallback<?>AmqpInboundChannelAdapter.Listener.recoverer型 RecoveryCallback のパラメーターを持つ org.springframework.integration.amqp.inbound のメソッド修飾子と型メソッド説明voidAmqpInboundChannelAdapter.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) アダプター内で再試行を使用する場合は、RecoveryCallbackを設定してください。voidAmqpInboundGateway.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) ゲートウェイ内で再試行を使用する場合は、RecoveryCallbackを設定します。org.springframework.integration.handler.advice 内の RecoveryCallback 使用
型 RecoveryCallback のパラメーターを持つ org.springframework.integration.handler.advice のメソッド修飾子と型メソッド説明voidRequestHandlerRetryAdvice.setRecoveryCallback(RecoveryCallback<ObjectSE> recoveryCallback) RetryExceptionを処理するためにRecoveryCallbackを設定します。org.springframework.integration.jms.dsl 内の RecoveryCallback 使用
型 RecoveryCallback のパラメーターを持つ org.springframework.integration.jms.dsl のメソッド修飾子と型メソッド説明JmsInboundGatewaySpec.recoveryCallback(RecoveryCallback<Message<?>> recoveryCallback) アダプター内で再試行を使用する場合は、RecoveryCallbackを設定してください。JmsMessageDrivenChannelAdapterSpec.recoveryCallback(RecoveryCallback<Message<?>> recoveryCallback) アダプター内で再試行を使用する場合は、RecoveryCallbackを設定してください。org.springframework.integration.jms.inbound 内の RecoveryCallback 使用
型 RecoveryCallback のパラメーターを持つ org.springframework.integration.jms.inbound のメソッド修飾子と型メソッド説明voidChannelPublishingJmsMessageListener.setRecoveryCallback(RecoveryCallback<Message<?>> recoveryCallback) アダプター内で再試行を使用する場合は、RecoveryCallbackを設定してください。org.springframework.integration.kafka.dsl 内の RecoveryCallback 使用
型 RecoveryCallback のパラメーターを持つ org.springframework.integration.kafka.dsl のメソッド修飾子と型メソッド説明KafkaInboundGatewaySpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) 再試行操作用のRecoveryCallbackインスタンス。null の場合、再試行が何回も実行された後にコンテナーに例外がスローされます。KafkaMessageDrivenChannelAdapterSpec.recoveryCallback(RecoveryCallback<?> recoveryCallback) 再試行操作用のRecoveryCallbackインスタンス。null の場合、再試行が何回も実行された後にコンテナーに例外がスローされます。org.springframework.integration.kafka.inbound 内の RecoveryCallback 使用
型 RecoveryCallback のパラメーターを持つ org.springframework.integration.kafka.inbound のメソッド修飾子と型メソッド説明default 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, RunnableSE runnable) 再試行テンプレートと回復コールバックを使用してランナブルを実行します。voidKafkaInboundGateway.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) 再試行操作用のRecoveryCallbackインスタンス。null の場合、再試行回数が尽きた後にコンテナーに例外がスローされます (エラーチャネルが構成されていない限り)。voidKafkaMessageDrivenChannelAdapter.setRecoveryCallback(RecoveryCallback<?> recoveryCallback) 再試行操作用のRecoveryCallbackインスタンス。null の場合、再試行回数が尽きた後にコンテナーに例外がスローされます (エラーチャネルが構成されていない限り)。