Uses of Interface
org.springframework.pulsar.listener.MessageListenerContainer
Package
Description
Package containing Spring configuration classes for the framework.
Package containing listener components for receiving Pulsar messages.
Package containing listener components for receiving Pulsar messages.
-
Uses of MessageListenerContainer in org.springframework.pulsar.config
Modifier and TypeClassDescriptionclass
GenericListenerEndpointRegistry<C extends MessageListenerContainer,
E extends ListenerEndpoint<C>> Creates the necessary container instances for the registered endpoints.interface
ListenerContainerFactory<C extends MessageListenerContainer,
E extends ListenerEndpoint<C>> Factory for Pulsar message listener containers.interface
ListenerEndpoint<C extends MessageListenerContainer>
Model for a Pulsar listener endpoint. -
Uses of MessageListenerContainer in org.springframework.pulsar.listener
Modifier and TypeInterfaceDescriptioninterface
Internal abstraction used by the framework representing a message listener container.Modifier and TypeClassDescriptionclass
Base implementation for thePulsarMessageListenerContainer
.class
Creates a concurrent execution context ofDefaultPulsarMessageListenerContainer
instances based on theconcurrency
.class
Default implementation forPulsarMessageListenerContainer
.Modifier and TypeMethodDescriptionPulsarListenerContainerRegistry.getListenerContainer
(String id) Return the listener container with the specified id ornull
if no such container exists.Modifier and TypeMethodDescriptionCollection<? extends MessageListenerContainer>
PulsarListenerContainerRegistry.getAllListenerContainers()
Return all listener container instances including those managed by this registry and those declared as beans in the application context.Collection<? extends MessageListenerContainer>
PulsarListenerContainerRegistry.getListenerContainers()
Return the managed listener container instance(s). -
Uses of MessageListenerContainer in org.springframework.pulsar.reactive.listener
Modifier and TypeInterfaceDescriptioninterface
Internal abstraction used by the framework representing a reactive message listener container.Modifier and TypeClassDescriptionclass
Default implementation forReactivePulsarMessageListenerContainer
.