Uses of Interface
org.springframework.pulsar.reader.PulsarMessageReaderContainer
Packages that use PulsarMessageReaderContainer
Package
Description
Package containing Spring configuration classes for the framework.
-
Uses of PulsarMessageReaderContainer in org.springframework.pulsar.config
Classes in org.springframework.pulsar.config with type parameters of type PulsarMessageReaderContainerModifier 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
.Methods in org.springframework.pulsar.config with parameters of type PulsarMessageReaderContainerModifier 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) Method parameters in org.springframework.pulsar.config with type arguments of type PulsarMessageReaderContainerModifier and TypeMethodDescriptionprotected abstract C
AbstractPulsarReaderContainerFactory.createContainerInstance
(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) protected DefaultPulsarMessageReaderContainer<T>
DefaultPulsarReaderContainerFactory.createContainerInstance
(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) AbstractPulsarReaderContainerFactory.createRegisteredContainer
(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
Classes in org.springframework.pulsar.reader that implement PulsarMessageReaderContainerModifier and TypeClassDescriptionclass
Core implementation forPulsarMessageReaderContainer
.class
Default implementation for the Pulsar reader container.Methods in org.springframework.pulsar.reader that return PulsarMessageReaderContainerMethods in org.springframework.pulsar.reader that return types with arguments of type PulsarMessageReaderContainerModifier and TypeMethodDescriptionCollection<? extends PulsarMessageReaderContainer>
PulsarReaderContainerRegistry.getAllReaderContainers()
Collection<? extends PulsarMessageReaderContainer>
PulsarReaderContainerRegistry.getReaderContainers()