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.Subclasses with type arguments of type PulsarMessageReaderContainer in org.springframework.pulsar.configModifier and TypeClassDescriptionclassCreates the necessaryPulsarMessageReaderContainerinstances for the registered endpoints.classCreates the necessaryPulsarMessageReaderContainerinstances for the registered endpoints.Subinterfaces with type arguments of type PulsarMessageReaderContainer in org.springframework.pulsar.configModifier and TypeInterfaceDescriptioninterfaceContainer factory forPulsarMessageReaderContainer.interfaceContainer factory forPulsarMessageReaderContainer.Classes in org.springframework.pulsar.config that implement interfaces with type arguments of type PulsarMessageReaderContainerMethods 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()