Uses of Interface
org.springframework.pulsar.reactive.core.ReactiveMessageSenderBuilderCustomizer
Package
Description
Package containing the core reactive components of the framework.
-
Uses of ReactiveMessageSenderBuilderCustomizer in org.springframework.pulsar.reactive.core
Modifier and TypeMethodDescriptionReactivePulsarOperations.SendMessageBuilder.withSenderCustomizer
(ReactiveMessageSenderBuilderCustomizer<T> customizer) Specifies the customizer to use to further configure the reactive sender builder.ReactivePulsarTemplate.SendMessageBuilderImpl.withSenderCustomizer
(ReactiveMessageSenderBuilderCustomizer<T> senderCustomizer) Modifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageSender<T>
DefaultReactivePulsarSenderFactory.createSender
(String topic, org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageSenderBuilderCustomizer<T>> customizers) org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T>
ReactivePulsarSenderFactory.createSender
(String topic, org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageSenderBuilderCustomizer<T>> customizers) Create a reactive message sender.