Uses of Interface
org.springframework.pulsar.reader.PulsarMessageReaderContainer
Packages that use PulsarMessageReaderContainer
Package
Description
Package containing Spring configuration classes for the framework.
Package containing components to support Pulsar reader functionality.
-
Uses of PulsarMessageReaderContainer in org.springframework.pulsar.config
Classes in org.springframework.pulsar.config with type parameters of type PulsarMessageReaderContainerModifier and TypeClassDescriptionclassGenericReaderEndpointRegistry<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>> Creates the necessary container instances for the registered endpoints.interfacePulsarReaderEndpoint<C extends PulsarMessageReaderContainer>Model for a Pulsar Reader endpoint.interfaceReaderContainerFactory<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, @Nullable MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>MethodPulsarReaderEndpoint.createReaderListener(PulsarMessageReaderContainer container, @Nullable MessageConverter messageConverter) voidAbstractPulsarReaderEndpoint.setupListenerContainer(PulsarMessageReaderContainer listenerContainer, @Nullable MessageConverter messageConverter) Method parameters in org.springframework.pulsar.config with type arguments of type PulsarMessageReaderContainerModifier and TypeMethodDescriptionprotected abstract CAbstractPulsarReaderContainerFactory.createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) protected DefaultPulsarMessageReaderContainer<T>DefaultPulsarReaderContainerFactory.createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) AbstractPulsarReaderContainerFactory.createRegisteredContainer(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) protected voidAbstractPulsarReaderContainerFactory.initializeContainer(C instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint) protected voidDefaultPulsarReaderContainerFactory.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 TypeClassDescriptionclassCore implementation forPulsarMessageReaderContainer.classDefault implementation for the Pulsar reader container.Methods in org.springframework.pulsar.reader that return PulsarMessageReaderContainerModifier and TypeMethodDescription@Nullable PulsarMessageReaderContainerPulsarReaderContainerRegistry.getReaderContainer(String id) Methods in org.springframework.pulsar.reader that return types with arguments of type PulsarMessageReaderContainerModifier and TypeMethodDescriptionCollection<? extends PulsarMessageReaderContainer>PulsarReaderContainerRegistry.getAllReaderContainers()Collection<? extends PulsarMessageReaderContainer>PulsarReaderContainerRegistry.getReaderContainers()