Package org.springframework.pulsar.reactive.core
@NonNullApi
@NonNullFields
package org.springframework.pulsar.reactive.core
Package containing the core reactive components of the framework.
-
ClassDescriptionDefault implementation for
ReactivePulsarConsumerFactory
.Default implementation forReactivePulsarReaderFactory
.Default implementation ofReactivePulsarSenderFactory
.Builder forDefaultReactivePulsarSenderFactory
.The interface to customize aMessageSpecBuilder
.Callback interface that can be implemented to customize thebuilder
that is used by theReactivePulsarConsumerFactory
to create consumers.The interface to customize aReactiveMessageReaderBuilder
.The interface to customize aReactiveMessageSenderBuilder
.Pulsar reactive consumer factory interface.The Pulsar reactive send operations contract.Builder that can be used to configure and send a message.The strategy to create aReactiveMessageReader
instance(s).The strategy to create aReactiveMessageSender
instance(s).A template for executing high-level reactive Pulsar operations.