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 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, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>MethodPulsarReaderEndpoint.createReaderListener(PulsarMessageReaderContainer container, MessageConverter messageConverter) voidAbstractPulsarReaderEndpoint.setupListenerContainer(PulsarMessageReaderContainer listenerContainer, 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.createReaderContainer(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 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()