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.
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.
ConsumerConfigProperties	Configuration properties used to specify Pulsar consumers.
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.
Customer
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.
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.
FailoverConsumerApp
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.
ProducerConfigProperties	Configuration properties used to specify Pulsar producers.
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.
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.
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.
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.
PulsarBinderConfiguration	Pulsar binder Configuration.
PulsarBinderConfigurationProperties	@ConfigurationProperties for the Pulsar binder.
PulsarBindingProperties	Container for Pulsar specific extended producer and consumer binding properties.
PulsarBootstrapConfiguration	An ImportBeanDefinitionRegistrar class that registers a PulsarListenerAnnotationBeanPostProcessor bean capable of processing Spring's @PulsarListener annotation.
PulsarClientFactoryBean	FactoryBean implementation for the PulsarClient.
PulsarConsumerErrorHandler<T>	Contract for consumer error handling through the message listener container.
PulsarConsumerFactory<T>	Pulsar consumer factory interface.
PulsarConsumerProperties	Pulsar consumer properties used by the binder.
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.
PulsarExtendedBindingProperties	@ConfigurationProperties for Pulsar binder specific extensions to the common binding properties.
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.
PulsarMessageChannelBinder	Binder implementation for Apache Pulsar.
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).
PulsarProducerProperties	Pulsar producer properties used by the binder.
PulsarProperties	Configuration properties for Spring for Apache Pulsar.
PulsarProperties.Admin
PulsarProperties.Cache
PulsarProperties.Client
PulsarProperties.Defaults
PulsarProperties.Function
PulsarProperties.Listener
PulsarProperties.Reader
PulsarProperties.SchemaInfo	Represents a schema - holds enough information to construct an actual schema instance.
PulsarProperties.Template
PulsarProperties.TypeMapping	A mapping from message type to topic and/or schema info to use (at least one of topicName or schemaInfo must be specified.
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.
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.
PulsarTestContainerSupport	Provides a static PulsarContainer that can be shared across test classes.
PulsarTopic	Model class for a Pulsar topic.
PulsarTopicBuilder	Builder class to create PulsarTopic instances.
PulsarTopicProvisioner	Pulsar topic provisioner.
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.
ReactiveSpringPulsarBootApp
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.
Signup
SignupApplication
SignupGenerator
SignupTier
SpringPulsarBinderSampleApp	This sample binder app has an extra consumer that is equipped with Pulsar's DLT feature - timeLoggerToDlt.
SpringPulsarBootApp
SpringPulsarReaderBootApp
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.