Uses of Class
org.springframework.kafka.listener.ConcurrentMessageListenerContainer
Packages that use ConcurrentMessageListenerContainer
Package
Description
Package for kafka configuration
Package for retryable topic handling.
-
Uses of ConcurrentMessageListenerContainer in org.springframework.kafka.config
Methods in org.springframework.kafka.config that return ConcurrentMessageListenerContainerModifier and TypeMethodDescriptionprotected ConcurrentMessageListenerContainer<K,
V> ConcurrentKafkaListenerContainerFactory.createContainerInstance
(KafkaListenerEndpoint endpoint) Methods in org.springframework.kafka.config with parameters of type ConcurrentMessageListenerContainerModifier and TypeMethodDescriptionprotected void
ConcurrentKafkaListenerContainerFactory.initializeContainer
(ConcurrentMessageListenerContainer<K, V> instance, KafkaListenerEndpoint endpoint) -
Uses of ConcurrentMessageListenerContainer in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic with parameters of type ConcurrentMessageListenerContainerModifier and TypeMethodDescriptionprotected void
ListenerContainerFactoryConfigurer.setupBackoffAwareMessageListenerAdapter
(ConcurrentMessageListenerContainer<?, ?> container) Method parameters in org.springframework.kafka.retrytopic with type arguments of type ConcurrentMessageListenerContainerModifier and TypeMethodDescriptionRetryTopicConfigurationSupport.CustomizersConfigurer.customizeListenerContainer
(Consumer<ConcurrentMessageListenerContainer<?, ?>> listenerContainerCustomizer) Customize theConcurrentMessageListenerContainer
instances created for the retry and DLT consumers.void
ListenerContainerFactoryConfigurer.setContainerCustomizer
(Consumer<ConcurrentMessageListenerContainer<?, ?>> containerCustomizer)