Package org.springframework.pulsar.config
@NonNullApi
@NonNullFields
package org.springframework.pulsar.config
Package containing Spring configuration classes for the framework.
-
ClassDescriptionBase
PulsarListenerContainerFactory
implementation.Base implementation forPulsarListenerEndpoint
.BasePulsarReaderContainerFactory
implementation.Base implementation forPulsarListenerEndpoint
.Concrete implementation forPulsarListenerContainerFactory
.Deprecated, for removal: This API element is subject to removal in a future version.Concrete implementation forPulsarReaderContainerFactory
.Creates the necessary container instances for the registered endpoints.GenericReaderEndpointRegistry<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>> Creates the necessary container instances for the registered endpoints.Factory for Pulsar message listener containers.ListenerEndpoint<C extends MessageListenerContainer>Model for a Pulsar listener endpoint.APulsarListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint.APulsarReaderEndpoint
providing the method to invoke to process an incoming message for this endpoint.Constants for bean names that need to be accessed in multiple places by name.Factory for Pulsar message listener containers.Factory for Pulsar message listener containers.Model for a Pulsar listener endpoint.Helper bean for registeringListenerEndpoint
with aGenericListenerEndpointRegistry
.Creates the necessaryPulsarMessageListenerContainer
instances for the registered endpoints.Container factory forPulsarMessageReaderContainer
.PulsarReaderEndpoint<C extends PulsarMessageReaderContainer>Model for a Pulsar Reader endpoint.Helper bean for registeringPulsarReaderEndpoint
with aGenericReaderEndpointRegistry
.Creates the necessaryPulsarMessageReaderContainer
instances for the registered endpoints.Base container factory interface forPulsarMessageReaderContainer
.The action to take on the container when a failure occurs during startup.
org.springframework.boot.autoconfigure.pulsar.PulsarContainerFactoryCustomizer<ConcurrentPulsarListenerContainerFactory<?>>