Package org.springframework.pulsar.reactive.core

@NonNullApi @NonNullFields package org.springframework.pulsar.reactive.core

Package containing the core reactive components of the framework.

Class	Description
DefaultReactivePulsarConsumerFactory<T>	Default implementation for ReactivePulsarConsumerFactory.
DefaultReactivePulsarReaderFactory<T>	Default implementation for ReactivePulsarReaderFactory.
DefaultReactivePulsarSenderFactory<T>	Default implementation of ReactivePulsarSenderFactory.
DefaultReactivePulsarSenderFactory.Builder<T>	Builder for DefaultReactivePulsarSenderFactory.
MessageSpecBuilderCustomizer<T>	The interface to customize a MessageSpecBuilder.
ReactiveMessageConsumerBuilderCustomizer<T>	Callback interface that can be implemented to customize the builder that is used by the ReactivePulsarConsumerFactory to create consumers.
ReactiveMessageReaderBuilderCustomizer<T>	The interface to customize a ReactiveMessageReaderBuilder.
ReactiveMessageSenderBuilderCustomizer<T>	The interface to customize a ReactiveMessageSenderBuilder.
ReactivePulsarConsumerFactory<T>	Pulsar reactive consumer factory interface.
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).
ReactivePulsarSenderFactory<T>	The strategy to create a ReactiveMessageSender instance(s).
ReactivePulsarTemplate<T>	A template for executing high-level reactive Pulsar operations.