Uses of Interface
org.springframework.pulsar.listener.PulsarMessageListenerContainer
Packages that use PulsarMessageListenerContainer
Package
Description
Package containing Spring configuration classes for the framework.
Package containing listener components for receiving Pulsar messages.
-
Uses of PulsarMessageListenerContainer in org.springframework.pulsar.config
Methods in org.springframework.pulsar.config with parameters of type PulsarMessageListenerContainerModifier and TypeMethodDescriptionprotected abstract PulsarMessagingMessageListenerAdapter<K>AbstractPulsarListenerEndpoint.createMessageListener(PulsarMessageListenerContainer container, MessageConverter messageConverter) protected PulsarMessagingMessageListenerAdapter<V>MethodPulsarListenerEndpoint.createMessageListener(PulsarMessageListenerContainer container, MessageConverter messageConverter) voidAbstractPulsarListenerEndpoint.setupListenerContainer(PulsarMessageListenerContainer listenerContainer, MessageConverter messageConverter) voidPulsarListenerEndpointAdapter.setupListenerContainer(PulsarMessageListenerContainer listenerContainer, MessageConverter messageConverter) -
Uses of PulsarMessageListenerContainer in org.springframework.pulsar.listener
Classes in org.springframework.pulsar.listener that implement PulsarMessageListenerContainerModifier and TypeClassDescriptionclassBase implementation for thePulsarMessageListenerContainer.classCreates a concurrent execution context ofDefaultPulsarMessageListenerContainerinstances based on theconcurrency.classDefault implementation forPulsarMessageListenerContainer.Methods in org.springframework.pulsar.listener that return PulsarMessageListenerContainerModifier and TypeMethodDescriptionPulsarListenerContainerRegistry.getListenerContainer(String id) Methods in org.springframework.pulsar.listener that return types with arguments of type PulsarMessageListenerContainerModifier and TypeMethodDescriptionPulsarListenerContainerRegistry.getAllListenerContainers()PulsarListenerContainerRegistry.getListenerContainers()