Uses of Interface
org.springframework.pulsar.reader.PulsarMessageReaderContainer
Package
Description
Package containing Spring configuration classes for the framework.
-
Uses of PulsarMessageReaderContainer in org.springframework.pulsar.config
Modifier and TypeClassDescriptionclass
GenericReaderEndpointRegistry<C extends PulsarMessageReaderContainer,
E extends PulsarReaderEndpoint<C>> Creates the necessary container instances for the registered endpoints.interface
PulsarReaderEndpoint<C extends PulsarMessageReaderContainer>
Model for a Pulsar Reader endpoint.interface
ReaderContainerFactory<C extends PulsarMessageReaderContainer,
E extends PulsarReaderEndpoint<C>> Base container factory interface forPulsarMessageReaderContainer
.Modifier and TypeMethodDescriptionprotected abstract AbstractPulsarMessageToSpringMessageAdapter<K>
AbstractPulsarReaderEndpoint.createReaderListener
(PulsarMessageReaderContainer container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
MethodPulsarReaderEndpoint.createReaderListener
(PulsarMessageReaderContainer container, MessageConverter messageConverter) void
AbstractPulsarReaderEndpoint.setupListenerContainer
(PulsarMessageReaderContainer listenerContainer, MessageConverter messageConverter) Modifier and TypeMethodDescriptionprotected abstract C
AbstractPulsarReaderContainerFactory.createContainerInstance
(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) protected DefaultPulsarMessageReaderContainer<T>
DefaultPulsarReaderContainerFactory.createContainerInstance
(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) AbstractPulsarReaderContainerFactory.createReaderContainer
(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) protected void
AbstractPulsarReaderContainerFactory.initializeContainer
(C instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) protected void
DefaultPulsarReaderContainerFactory.initializeContainer
(DefaultPulsarMessageReaderContainer<T> instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) -
Uses of PulsarMessageReaderContainer in org.springframework.pulsar.reader
Modifier and TypeClassDescriptionclass
Core implementation forPulsarMessageReaderContainer
.class
Default implementation for the Pulsar reader container.Modifier and TypeMethodDescriptionCollection<? extends PulsarMessageReaderContainer>
PulsarReaderContainerRegistry.getAllReaderContainers()
Collection<? extends PulsarMessageReaderContainer>
PulsarReaderContainerRegistry.getReaderContainers()