All Classes and Interfaces

Class	Description
AbstractPulsarAnnotationsBeanPostProcessor	Base class implementation for the various annotation post processors in Spring Pulsar.
AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope
AbstractPulsarHeaderMapper<ToPulsarHeadersContextType,ToSpringHeadersContextType>	Base PulsarHeaderMapper implementation that constrains which headers are mapped via header matchers.
AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T>	Base PulsarListenerContainerFactory implementation.
AbstractPulsarListenerEndpoint<K>	Base implementation for PulsarListenerEndpoint.
AbstractPulsarMessageContainer	Base class for the various container implementations.
AbstractPulsarMessageListenerContainer<T>	Base implementation for the PulsarMessageListenerContainer.
AbstractPulsarMessageReaderContainer<T>	Core implementation for PulsarMessageReaderContainer.
AbstractPulsarMessageToSpringMessageAdapter<V>	An abstract MessageListener adapter providing the necessary infrastructure to extract the payload from a Pulsar message.
AbstractPulsarReaderContainerFactory<C extends AbstractPulsarMessageReaderContainer<T>,T>	Base PulsarReaderContainerFactory implementation.
AbstractPulsarReaderEndpoint<K>	Base implementation for PulsarListenerEndpoint.
AbstractReactivePulsarListenerEndpoint<T>	Base implementation for ReactivePulsarListenerEndpoint.
AckMode	Enumeration for ack mode.
Acknowledgement	Contract for manual acknowledgment.
CacheProvider<K,V>	Defines the contract for a cache provider.
CacheProviderFactory<K,V>	Interface to create instances of CacheProvider.
CacheProviderFactory.EvictionListener<K,V>	Interface for a cache eviction listener.
CachingPulsarProducerFactory<T>	A PulsarProducerFactory that extends the default implementation by caching the created producers.
CaffeineCacheProvider<K,V>	Cache provider implementation backed by a Caffeine cache.
CaffeineCacheProviderFactory<K,V>	Factory to create instances of CaffeineCacheProvider.
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.
DefaultPulsarClientFactory	Default implementation for PulsarClientFactory.
DefaultPulsarConsumerErrorHandler<T>	Default implementation for PulsarConsumerErrorHandler.
DefaultPulsarConsumerFactory<T>	Default implementation for PulsarConsumerFactory.
DefaultPulsarListenerObservationConvention	Default PulsarListenerObservationConvention for Pulsar listener key values.
DefaultPulsarMessageListenerContainer<T>	Default implementation for PulsarMessageListenerContainer.
DefaultPulsarMessageReaderContainer<T>	Default implementation for the Pulsar reader container.
DefaultPulsarProducerFactory<T>	Default implementation of PulsarProducerFactory.
DefaultPulsarReaderContainerFactory<T>	Concrete implementation for PulsarReaderContainerFactory.
DefaultPulsarReaderFactory<T>	Default implementation of PulsarReaderFactory.
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.
DefaultReactivePulsarSenderFactory.Builder<T>	Builder for DefaultReactivePulsarSenderFactory.
DefaultSchemaResolver	Default schema resolver capable of handling basic message types.
DefaultTopicResolver	Topic resolver that accepts custom type to topic mappings and uses the mappings during topic resolution.
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.
GenericListenerEndpointRegistry<C extends MessageListenerContainer,E extends ListenerEndpoint<C>>	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.
HandlerAdapter	A wrapper for either an InvocableHandlerMethod or DelegatingInvocableHandler.
InvocationResult	The result of a method invocation.
JacksonUtils	The utilities for Jackson ObjectMapper instances.
JavaUtils	Chained utility methods to simplify some Java repetitive code.
JsonPulsarHeaderMapper	A PulsarHeaderMapper implementation that writes headers as JSON.
JsonPulsarHeaderMapper.JsonPulsarHeaderMapperBuilder
JsonPulsarHeaderMapper.NonTrustedHeaderType	Represents a header that could not be decoded due to an untrusted type.
JsonPulsarHeaderMapper.ToPulsarHeadersContext	Context used for AbstractPulsarHeaderMapper.toPulsarHeaders(org.springframework.messaging.MessageHeaders) (outbound) that includes the cumulative map of header name to classname for headers that are serialized with JSON.
JsonPulsarHeaderMapper.ToSpringHeadersContext	Context used for AbstractPulsarHeaderMapper.toSpringHeaders(org.apache.pulsar.client.api.Message<?>) (inbound) that includes the cumulative map of header name to classname for headers in the incoming message that were serialized with JSON.
ListenerContainerFactory<C extends MessageListenerContainer,E extends ListenerEndpoint<C>>	Factory for Pulsar message listener containers.
ListenerEndpoint<C extends MessageListenerContainer>	Model for a Pulsar listener endpoint.
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.
MethodPulsarReaderEndpoint<V>	A PulsarReaderEndpoint 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.
ProducerBuilderConfigurationUtil	Utility methods to help load configuration into a ProducerBuilder.
ProducerBuilderCustomizer<T>	The interface to customize a ProducerBuilder.
PulsarAcknowledgingMessageListener<T>	Message listener for manually acknowledging messages.
PulsarAdminBuilderCustomizer	The interface to customize a PulsarAdminBuilder.
PulsarAdministration	An administration class that delegates to PulsarAdmin to create and manage topics defined in the application context.
PulsarAdministrationOperations	The Pulsar administration contract.
PulsarAnnotationsConfigurationSelector	A DeferredImportSelector implementation with the lowest order to import PulsarBootstrapConfiguration as late as possible.
PulsarAnnotationSupportBeanNames	Constants for bean names that need to be accessed in multiple places by name.
PulsarBatchAcknowledgingMessageListener<T>	Batch message listener that allows manual acknowledgment.
PulsarBatchListenerFailedException	Batch message listeners should throw this exception in the event of an error.
PulsarBatchMessageListener<T>	Batch message listener.
PulsarBatchMessagesToSpringMessageListenerAdapter<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.
PulsarClientBuilderCustomizer	The interface to customize a ClientBuilder.
PulsarClientFactory	Pulsar client factory interface.
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.
PulsarFunction	Represents a user-defined Pulsar Function backed by a FunctionConfig.
PulsarFunctionAdministration	Responsible for creating and updating any user-defined Pulsar functions, sinks, or sources.
PulsarFunctionAdministration.PulsarFunctionException	Indicates a failure of one or more function operations.
PulsarFunctionOperations<T>	Provides operations for a particular function type.
PulsarFunctionOperations.FunctionStopPolicy	The action to take on the function when the server stops.
PulsarFunctionOperations.FunctionType	The type of function the operations handle.
PulsarHeaderMapper	Defines the contract for mapping Spring Messaging MessageHeaders to and from Pulsar message headers.
PulsarHeaderMatcher	Defines the contract for matching message headers.
PulsarHeaderMatcher.NeverMatch	A matcher that never matches a set of headers.
PulsarHeaderMatcher.PatternMatch	A pattern-based header matcher that matches if the specified header matches the specified simple pattern.
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.
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 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 GenericListenerEndpointRegistry.
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.
PulsarMessageConverter<T>	Pulsar specific record converter strategy.
PulsarMessageListenerContainer	Internal abstraction used by the framework representing a message listener container.
PulsarMessageReaderContainer	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.
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).
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.
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.
PulsarReader
PulsarReaderAnnotationBeanPostProcessor<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 PulsarReaderContainerFactory according to the parameters of the annotation.
PulsarReaderConfigurer	Optional interface to be implemented by Spring managed bean willing to customize how Pulsar listener endpoints are configured.
PulsarReaderContainerFactory	Container factory for PulsarMessageReaderContainer.
PulsarReaderContainerProperties	Container properties for Pulsar Reader.
PulsarReaderContainerRegistry	Reader container registry.
PulsarReaderEndpoint<C extends PulsarMessageReaderContainer>	Model for a Pulsar Reader endpoint.
PulsarReaderEndpointRegistrar	Helper bean for registering PulsarReaderEndpoint with a GenericReaderEndpointRegistry.
PulsarReaderEndpointRegistry	Creates the necessary PulsarMessageReaderContainer instances for the registered endpoints.
PulsarReaderFactory<T>	Pulsar Reader factory interface.
PulsarRecordMessageConverter<V>	A Messaging MessageConverter implementation for a message listener that receives individual messages.
PulsarRecordMessageListener<T>	Base record MessageListener that simply extends from MessageListener.
PulsarRecordMessageToSpringMessageListenerAdapter<V>	A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive individual messages.
PulsarRecordMessageToSpringMessageReaderAdapter<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.
PulsarSink	Represents a Pulsar Sink backed by a SinkConfig.
PulsarSource	Represents a Pulsar Source backed by a SourceConfig.
PulsarTemplate<T>	A 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.
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.SendManyMessageBuilder<T>
ReactivePulsarOperations.SendMessageBuilder<O,T>	Builder that can be used to configure and send a message.
ReactivePulsarOperations.SendOneMessageBuilder<T>
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 template for executing high-level reactive Pulsar operations.
ReaderBuilderCustomizer<T>	The interface to customize a ReaderBuilder.
ReaderContainerFactory<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>	Base container factory interface for PulsarMessageReaderContainer.
ReaderFailedToStartEvent	Event to publish when the reader is failed to start.
ReaderStartedEvent	Event to publish when the reader is started.
ReaderStartingEvent	Event to publish while the reader is starting.
Resolved<T>	A resolved value or an exception if it could not be resolved.
SchemaResolver	Resolves schema to use for message types.
SchemaResolver.SchemaResolverCustomizer<T extends SchemaResolver>	Callback interface that can be implemented by beans wishing to customize the schema resolver before it is fully initialized, in particular to tune its configuration.
TopicResolver	Resolves topics to use when producing or consuming.
ToStringPulsarHeaderMapper	A PulsarHeaderMapper that converts header values using simple 'toString'.
TypedMessageBuilderCustomizer<T>	The interface to customize a TypedMessageBuilder.