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 voidConcurrentKafkaListenerContainerFactory.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 voidListenerContainerFactoryConfigurer.setupBackoffAwareMessageListenerAdapter(ConcurrentMessageListenerContainer<?, ?> container, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration, boolean isSetContainerProperties) Method parameters in org.springframework.kafka.retrytopic with type arguments of type ConcurrentMessageListenerContainerModifier and TypeMethodDescriptionRetryTopicConfigurationSupport.CustomizersConfigurer.customizeListenerContainer(Consumer<ConcurrentMessageListenerContainer<?, ?>> listenerContainerCustomizer) Customize theConcurrentMessageListenerContainerinstances created for the retry and DLT consumers.voidListenerContainerFactoryConfigurer.setContainerCustomizer(Consumer<ConcurrentMessageListenerContainer<?, ?>> containerCustomizer)