クラス RetryTopicConfigurationSupport.CustomizersConfigurer
java.lang.ObjectSE
org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.CustomizersConfigurer
- 含まれているクラス:
- RetryTopicConfigurationSupport
トピックの再試行機能によってインスタンス化されたコンポーネントのカスタマイザーを構成します。
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明レコードを再試行トピックおよび DLT に転送するために使用されるDeadLetterPublishingRecoverer
をカスタマイズします。customizeErrorHandler
(ConsumerSE<DefaultErrorHandler> errorHandlerCustomizer) 機能に使用されるCommonErrorHandler
インスタンスをカスタマイズします。customizeListenerContainer
(ConsumerSE<ConcurrentMessageListenerContainer<?, ?>> listenerContainerCustomizer) 再試行および DLT コンシューマー用に作成されたConcurrentMessageListenerContainer
インスタンスをカスタマイズします。
コンストラクターの詳細
CustomizersConfigurer
public CustomizersConfigurer()
メソッドの詳細
customizeErrorHandler
public RetryTopicConfigurationSupport.CustomizersConfigurer customizeErrorHandler(ConsumerSE<DefaultErrorHandler> errorHandlerCustomizer) 機能に使用されるCommonErrorHandler
インスタンスをカスタマイズします。- パラメーター:
errorHandlerCustomizer
- カスタマイザー。- 戻り値:
- コンフィギュレーター。
- 関連事項:
customizeListenerContainer
public RetryTopicConfigurationSupport.CustomizersConfigurer customizeListenerContainer(ConsumerSE<ConcurrentMessageListenerContainer<?, ?>> listenerContainerCustomizer) 再試行および DLT コンシューマー用に作成されたConcurrentMessageListenerContainer
インスタンスをカスタマイズします。- パラメーター:
listenerContainerCustomizer
- カスタマイザー。- 戻り値:
- コンフィギュレーター。
customizeDeadLetterPublishingRecoverer
public RetryTopicConfigurationSupport.CustomizersConfigurer customizeDeadLetterPublishingRecoverer(ConsumerSE<DeadLetterPublishingRecoverer> dlprCustomizer) レコードを再試行トピックおよび DLT に転送するために使用されるDeadLetterPublishingRecoverer
をカスタマイズします。- パラメーター:
dlprCustomizer
- カスタマイザー。- 戻り値:
- コンフィギュレーター。