Closed
Description
The concurrency
attribute for the non-reactive listener should be specified on the PulsarContainerProperties
rather than the ConcurrentPulsarMessageListenerContainerFactory
.
The ConcurrentPulsarListenerContainerFactory#initializeContainer
method can simply ask the PulsarContainerProperties
for the concurrency rather than store it.
Motivation
- consistency w/ Reactive counterpart
- consistency w/ other container properties
- simplify SpringBoot property mapping (example)