クラス 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- カスタマイザー。- 戻り値:
- コンフィギュレーター。