クラスの使用
org.springframework.kafka.support.EndpointHandlerMethod
パッケージ
説明
再試行可能なトピック処理用のパッケージ。
kafka サポート用パッケージ
org.springframework.kafka.retrytopic 内の EndpointHandlerMethod 使用
修飾子と型フィールド説明static final EndpointHandlerMethod
RetryTopicConfigurer.DEFAULT_DLT_HANDLER
DLT でメッセージを処理するためのデフォルトの方法。修飾子と型メソッド説明static EndpointHandlerMethod
RetryTopicConfigurer.createHandlerMethodWith
(ObjectSE bean, MethodSE method) static EndpointHandlerMethod
RetryTopicConfigurer.createHandlerMethodWith
(ObjectSE beanOrClass, StringSE methodName) RetryTopicConfiguration.getDltHandlerMethod()
protected EndpointHandlerMethod
RetryTopicConfigurer.getEndpointHandlerMethod
(MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, DestinationTopic.Properties props) 修飾子と型メソッド説明protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> RetryTopicConfigurer.createEndpointCustomizer
(EndpointHandlerMethod endpointBeanMethod, DestinationTopic.Properties destinationTopicProperties) RetryTopicConfigurationBuilder.dltHandlerMethod
(EndpointHandlerMethod endpointHandlerMethod) DLT ハンドラーメソッドを設定します。修飾子コンストラクター説明EndpointCustomizerFactory
(DestinationTopic.Properties destinationProperties, EndpointHandlerMethod beanMethod, BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) org.springframework.kafka.support 内の EndpointHandlerMethod 使用