All Classes and Interfaces

Class	Description
AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T>	Base PulsarListenerContainerFactory implementation.
AbstractPulsarListenerEndpoint<K>	Base implementation for PulsarListenerEndpoint.
AbstractPulsarMessageListenerContainer<T>	Base implementation for the PulsarMessageListenerContainer.
AbstractReactivePulsarListenerEndpoint<T>	Base implementation for ReactivePulsarListenerEndpoint.
AckMode	Enumeration for ack mode.
Acknowledgement	Contract for manual acknowledgment.
CachingPulsarProducerFactory<T>	A PulsarProducerFactory that extends the default implementation by caching the created producers.
ConcurrentPulsarListenerContainerFactory<T>	Concrete implementation for PulsarListenerContainerFactory.
ConcurrentPulsarMessageListenerContainer<T>	Creates a concurrent execution context of DefaultPulsarMessageListenerContainer instances based on the concurrency.
ConsumerBuilderConfigurationUtil	Utility methods to help load configuration into a ConsumerBuilder.
ConsumerBuilderCustomizer<T>	The interface to customize a ConsumerBuilder.
ConsumerFailedToStartEvent	Event to publish when the consumer is failed to start.
ConsumerStartedEvent	Event to publish when the consumer is started.
ConsumerStartingEvent	Event to publish while the consumer is starting.
DefaultPulsarConsumerErrorHandler<T>	Default implementation for PulsarConsumerErrorHandler.
DefaultPulsarConsumerFactory<T>	Default implementation for PulsarConsumerFactory.
DefaultPulsarListenerObservationConvention	Default PulsarListenerObservationConvention for Pulsar listener key values.
DefaultPulsarMessageHeaderMapper	Implementation of PulsarMessageHeaderMapper.
DefaultPulsarMessageListenerContainer<T>	Default implementation for PulsarMessageListenerContainer.
DefaultPulsarProducerFactory<T>	Default implementation of PulsarProducerFactory.
DefaultPulsarTemplateObservationConvention	Default PulsarTemplateObservationConvention for Pulsar template key values.
DefaultReactivePulsarConsumerFactory<T>	Default implementation for ReactivePulsarConsumerFactory.
DefaultReactivePulsarListenerContainerFactory<T>	Concrete implementation for ReactivePulsarListenerContainerFactory.
DefaultReactivePulsarMessageListenerContainer<T>	Default implementation for ReactivePulsarMessageListenerContainer.
DefaultReactivePulsarReaderFactory<T>	Default implementation for ReactivePulsarReaderFactory.
DefaultReactivePulsarSenderFactory<T>	Default implementation of ReactivePulsarSenderFactory.
DelegatingInvocableHandler	Delegates to an InvocableHandlerMethod based on the message payload type.
EnablePulsar	Enables detection of PulsarListener annotations on any Spring-managed bean in the container.
EnableReactivePulsar	Enables detection of ReactivePulsarListener annotations on any Spring-managed bean in the container.
FailoverConsumerApp
HandlerAdapter	A wrapper for either an InvocableHandlerMethod or DelegatingInvocableHandler.
InvocationResult	The result of a method invocation.
JavaUtils	Chained utility methods to simplify some Java repetitive code.
ListenerContainerFactory<C extends MessageListenerContainer,E extends ListenerEndpoint<C>>	Factory for Pulsar message listener containers.
ListenerContainerRegistry	A registry for containers.
ListenerEndpoint<C extends MessageListenerContainer>	Model for a Pulsar listener endpoint.
ListenerEndpointRegistry<C extends MessageListenerContainer,E extends ListenerEndpoint<C>>	Creates the necessary container instances for the registered endpoints.
MessageConverter	Pulsar specific message converter.
MessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
MessageSpecBuilderCustomizer<T>	The interface to customize a MessageSpecBuilder.
MethodPulsarListenerEndpoint<V>	A PulsarListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.
MethodReactivePulsarListenerEndpoint<V>	A ReactivePulsarListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.
ProducerBuilderCustomizer<T>	The interface to customize a ProducerBuilder.
PulsarAcknowledgingMessageListener<T>	Message listener for manually acknowledging messages.
PulsarAdministration	An administration class that delegates to PulsarAdmin to create and manage topics defined in the application context.
PulsarAdministrationOperations	The Pulsar administration contract.
PulsarAnnotationDrivenConfiguration	Configuration for Pulsar annotation-driven support.
PulsarAutoConfiguration	Auto-configuration for Apache Pulsar.
PulsarBatchAcknowledgingMessageListener<T>	Batch message listener that allows manual acknowledgment.
PulsarBatchListenerFailedException	Batch message listeners should throw this exception in the event of an error.
PulsarBatchMessageConverter<T>	Pulsar batch message converter strategy.
PulsarBatchMessageListener<T>	Batch message listener.
PulsarBatchMessagingMessageConverter<T>	Batch records message converter.
PulsarBatchMessagingMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive batches of messages.
PulsarBootstrapConfiguration	An ImportBeanDefinitionRegistrar class that registers a PulsarListenerAnnotationBeanPostProcessor bean capable of processing Spring's @PulsarListener annotation.
PulsarClientConfiguration	Configuration for the Pulsar client.
PulsarClientFactoryBean	FactoryBean implementation for the PulsarClient.
PulsarConsumerErrorHandler<T>	Contract for consumer error handling through the message listener container.
PulsarConsumerFactory<T>	Pulsar consumer factory interface.
PulsarContainerProperties	Contains runtime properties for a listener container.
PulsarDeadLetterPublishingRecoverer<T>	PulsarMessageRecoverer implementation that is capable of recovering the message by publishing the failed record to a DLT - Dead Letter Topic.
PulsarEvent	Base class for events.
PulsarException	Spring Pulsar specific NestedRuntimeException implementation.
PulsarHeaders	Pulsar specific message headers.
PulsarListener	Annotation that marks a method to be the target of a Pulsar message listener on the specified topics.
PulsarListenerAnnotationBeanPostProcessor<V>	Bean post-processor that registers methods annotated with PulsarListener to be invoked by a Pulsar message listener container created under the covers by a PulsarListenerContainerFactory according to the parameters of the annotation.
PulsarListenerAnnotationBeanPostProcessor.AnnotationEnhancer
PulsarListenerBeanNames	Constants for bean names that need to be accessed in multiple places by name.
PulsarListenerConfigurationSelector	A DeferredImportSelector implementation with the lowest order to import PulsarBootstrapConfiguration as late as possible.
PulsarListenerConfigurer	Optional interface to be implemented by Spring managed bean willing to customize how Pulsar listener endpoints are configured.
PulsarListenerContainerFactory	Factory for Pulsar message listener containers.
PulsarListenerContainerRegistry	A registry for listener containers.
PulsarListenerEndpoint	Model for a Pulsar listener endpoint.
PulsarListenerEndpointAdapter	Adapter to avoid having to implement all methods.
PulsarListenerEndpointRegistrar	Helper bean for registering ListenerEndpoint with a ListenerEndpointRegistry.
PulsarListenerEndpointRegistry	Creates the necessary PulsarMessageListenerContainer instances for the registered endpoints.
PulsarListenerObservation	An Observation for a PulsarListener.
PulsarListenerObservation.ListenerLowCardinalityTags	Low cardinality tags.
PulsarListenerObservationConvention	ObservationConvention for Pulsar listener key values.
PulsarListeners	Container annotation that aggregates several PulsarListener annotations.
PulsarMessageHeaderMapper	API for Pulsar message header mapper.
PulsarMessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
PulsarMessageReceiverContext	ReceiverContext for Pulsar messages.
PulsarMessageRecoverer<T>	Allows recovering a failed Pulsar message.
PulsarMessageRecovererFactory<T>	Factory interface for PulsarMessageRecoverer.
PulsarMessageSenderContext	SenderContext for Pulsar messages.
PulsarMessageSenderContext.MessageHolder	Acts as a carrier for a Pulsar message and records the propagated properties for later access by the Pulsar message builder.
PulsarMessagingMessageConverter<V>	A Messaging MessageConverter implementation for a message listener that receives individual messages.
PulsarMessagingMessageListenerAdapter<V>	An abstract MessageListener adapter providing the necessary infrastructure to extract the payload from a Pulsar message.
PulsarOperations<T>	The basic Pulsar operations contract.
PulsarOperations.SendMessageBuilder<T>	Builder that can be used to configure and send a message.
PulsarProducerFactory<T>	The strategy to create a Producer instance(s).
PulsarProperties	Configuration properties for Spring for Apache Pulsar.
PulsarProperties.Admin
PulsarProperties.Cache
PulsarProperties.Client
PulsarProperties.Consumer
PulsarProperties.Listener
PulsarProperties.Producer
PulsarProperties.Template
PulsarReactiveAnnotationDrivenConfiguration	Configuration for Reactive Pulsar annotation-driven support.
PulsarReactiveAutoConfiguration	Auto-configuration for Apache Pulsar.
PulsarReactiveMessagingMessageListenerAdapter<V>	An abstract base for MessageListener adapters.
PulsarReactiveOneByOneMessagingMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
PulsarReactiveProperties	Configuration properties for Spring for the Apache Pulsar reactive client.
PulsarReactiveProperties.Cache
PulsarReactiveProperties.Consumer
PulsarReactiveProperties.Listener
PulsarReactiveProperties.Reader
PulsarReactiveProperties.SchedulerType
PulsarReactiveProperties.Sender
PulsarReactiveStreamingMessagingMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive a flux of messages.
PulsarRecordMessageConverter<T>	Pulsar specific record converter strategy.
PulsarRecordMessageListener<T>	Base record MessageListener that simply extends from MessageListener.
PulsarRecordMessagingMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
PulsarRecordMessagingMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
PulsarRuntimeHints	RuntimeHintsRegistrar for Spring for Apache Pulsar.
PulsarTemplate<T>	A thread-safe template for executing high-level Pulsar operations.
PulsarTemplate.SendMessageBuilderImpl<T>
PulsarTemplateObservation	An Observation for PulsarTemplate.
PulsarTemplateObservation.TemplateLowCardinalityTags	Low cardinality tags.
PulsarTemplateObservationConvention	ObservationConvention for Pulsar template key values.
PulsarTopic	Model class for a Pulsar topic.
PulsarTopicBuilder	Builder class to create PulsarTopic instances.
ReactiveMessageConsumerBuilderCustomizer<T>	The interface to customize a ReactiveMessageConsumerBuilder.
ReactiveMessageReaderBuilderCustomizer<T>	The interface to customize a ReactiveMessageReaderBuilder.
ReactiveMessageSenderBuilderCustomizer<T>	The interface to customize a ReactiveMessageSenderBuilder.
ReactivePulsarBootstrapConfiguration	An ImportBeanDefinitionRegistrar class that registers a ReactivePulsarListenerAnnotationBeanPostProcessor bean capable of processing Spring's @ReactivePulsarListener annotation.
ReactivePulsarConsumerFactory<T>	Pulsar reactive consumer factory interface.
ReactivePulsarContainerProperties<T>	Contains runtime properties for a reactive listener container.
ReactivePulsarListener	Annotation that marks a method to be the target of a Pulsar message listener on the specified topics.
ReactivePulsarListenerAnnotationBeanPostProcessor<V>	Bean post-processor that registers methods annotated with ReactivePulsarListener to be invoked by a Pulsar message listener container created under the covers by a ReactivePulsarListenerContainerFactory according to the parameters of the annotation.
ReactivePulsarListenerAnnotationBeanPostProcessor.AnnotationEnhancer
ReactivePulsarListenerConfigurationSelector	A DeferredImportSelector implementation with the lowest order to import ReactivePulsarBootstrapConfiguration as late as possible.
ReactivePulsarListenerContainerFactory<T>	Factory for Pulsar reactive message listener containers.
ReactivePulsarListenerEndpoint<T>	Model for a Pulsar reactive listener endpoint.
ReactivePulsarListenerEndpointAdapter<T>	Adapter to avoid having to implement all methods.
ReactivePulsarListenerEndpointRegistry<T>	Creates the necessary ReactivePulsarMessageListenerContainer instances for the registered endpoints.
ReactivePulsarListeners	Container annotation that aggregates several ReactivePulsarListener annotations.
ReactivePulsarMessageHandler	Reactive message handler used by DefaultReactivePulsarMessageListenerContainer.
ReactivePulsarMessageListenerContainer<T>	Internal abstraction used by the framework representing a reactive message listener container.
ReactivePulsarOneByOneMessageHandler<T>	Message handler class with a ReactivePulsarOneByOneMessageHandler.received(org.apache.pulsar.client.api.Message<T>) method for use in ReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>).
ReactivePulsarOperations<T>	The Pulsar reactive send operations contract.
ReactivePulsarOperations.SendMessageBuilder<T>	Builder that can be used to configure and send a message.
ReactivePulsarReaderFactory<T>	The strategy to create a ReactiveMessageReader instance(s).
ReactivePulsarRuntimeHints	RuntimeHintsRegistrar for Spring for Apache Pulsar.
ReactivePulsarSenderFactory<T>	The strategy to create a ReactiveMessageSender instance(s).
ReactivePulsarStreamingHandler<T>	Message handler class with a ReactivePulsarStreamingHandler.received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>) method for use in ReactiveMessagePipelineBuilder.streamingMessageHandler(java.util.function.Function<reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>, org.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<java.lang.Void>>>).
ReactivePulsarTemplate<T>	A thread-safe template for executing high-level reactive Pulsar operations.
ReactivePulsarTemplate.SendMessageBuilderImpl<T>
ReactiveSpringPulsarBootApp
SchemaUtils	Utility class for Pulsar schema inference.
SpringPulsarBootApp
TypedMessageBuilderCustomizer<T>	The interface to customize a TypedMessageBuilder.