クラス EndpointCustomizerFactory
java.lang.ObjectSE
org.springframework.kafka.retrytopic.EndpointCustomizerFactory
RetryTopicConfigurer がメインエンドポイント、再試行エンドポイント、DLT エンドポイントをカスタマイズするために使用する EndpointCustomizer を作成します。- 導入:
- 2.7.2
- 作成者:
- Tomaz Fernandes, Gary Russell, Wang Zhiyang
- 関連事項:
コンストラクターのサマリー
コンストラクターコンストラクター説明EndpointCustomizerFactory(DestinationTopic.Properties destinationProperties, EndpointHandlerMethod beanMethod, BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) メソッドのサマリー
修飾子と型メソッド説明protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,?>> addSuffixesAndMethod(DestinationTopic.Properties properties) MethodKafkaListenerEndpoint の EndpointCustomizer を作成し、MultiMethodKafkaListenerEndpoint をサポートします。protected EndpointCustomizeraddSuffixesAndMethod(DestinationTopic.Properties properties, ObjectSE bean, MethodSE method) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。final EndpointCustomizer<MethodKafkaListenerEndpoint<?,?>> protected CollectionSE<EndpointCustomizer.TopicNamesHolder>customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?, ?> endpoint)
コンストラクターの詳細
EndpointCustomizerFactory
public EndpointCustomizerFactory(DestinationTopic.Properties destinationProperties, EndpointHandlerMethod beanMethod, BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)
メソッドの詳細
createEndpointCustomizer
addSuffixesAndMethod
@DeprecatedSE(since="3.2", forRemoval=true) protected EndpointCustomizer addSuffixesAndMethod(DestinationTopic.Properties properties, ObjectSE bean, MethodSE method) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。MethodKafkaListenerEndpoint の EndpointCustomizer を作成しますが、MultiMethodKafkaListenerEndpoint はサポートしていません。addSuffixesAndMethod(DestinationTopic.Properties)に置き換えます。- パラメーター:
properties- 宛先トピックのプロパティ。bean- Bean。method- メソッド。- 戻り値:
- エンドポイントカスタマイザー。
addSuffixesAndMethod
protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,?>> addSuffixesAndMethod(DestinationTopic.Properties properties) MethodKafkaListenerEndpoint の EndpointCustomizer を作成し、MultiMethodKafkaListenerEndpoint をサポートします。- パラメーター:
properties- 宛先トピックのプロパティ。- 戻り値:
- エンドポイントカスタマイザー。
- 導入:
- 3.2
customizeAndRegisterTopics
protected CollectionSE<EndpointCustomizer.TopicNamesHolder> customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?, ?> endpoint)