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
.The interface to customize aMessageSpecBuilder
.The interface to customize aReactiveMessageConsumerBuilder
.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 thread-safe template for executing high-level reactive Pulsar operations.