Uses of Interface
org.springframework.pulsar.config.PulsarReaderEndpoint

Packages that use PulsarReaderEndpoint

Package	Description
org.springframework.pulsar.config	Package containing Spring configuration classes for the framework.

Uses of PulsarReaderEndpoint in org.springframework.pulsar.config

Classes in org.springframework.pulsar.config with type parameters of type PulsarReaderEndpoint

Modifier and Type	Class	Description
class	GenericReaderEndpointRegistry<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>	Creates the necessary container instances for the registered endpoints.
interface	ReaderContainerFactory<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>	Base container factory interface for PulsarMessageReaderContainer.

Classes in org.springframework.pulsar.config that implement PulsarReaderEndpoint

Modifier and Type	Class	Description
class	AbstractPulsarReaderEndpoint<K>	Base implementation for PulsarListenerEndpoint.
class	MethodPulsarReaderEndpoint<V>	A PulsarReaderEndpoint providing the method to invoke to process an incoming message for this endpoint.

Methods in org.springframework.pulsar.config with parameters of type PulsarReaderEndpoint

Modifier and Type	Method	Description
protected abstract C	AbstractPulsarReaderContainerFactory.createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
protected DefaultPulsarMessageReaderContainer<T>	DefaultPulsarReaderContainerFactory.createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
C	AbstractPulsarReaderContainerFactory.createReaderContainer(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
protected void	AbstractPulsarReaderContainerFactory.initializeContainer(C instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
protected void	DefaultPulsarReaderContainerFactory.initializeContainer(DefaultPulsarMessageReaderContainer<T> instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
void	PulsarReaderEndpointRegistrar.registerEndpoint(PulsarReaderEndpoint endpoint, ReaderContainerFactory<?,?> factory)