Uses of Class
org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory.Builder

Packages that use DefaultReactivePulsarSenderFactory.Builder

Package	Description
org.springframework.pulsar.reactive.core	Package containing the core reactive components of the framework.

Uses of DefaultReactivePulsarSenderFactory.Builder in org.springframework.pulsar.reactive.core

Methods in org.springframework.pulsar.reactive.core that return DefaultReactivePulsarSenderFactory.Builder

Modifier and Type	Method	Description
static <T> DefaultReactivePulsarSenderFactory.Builder<T>	DefaultReactivePulsarSenderFactory.builderFor(org.apache.pulsar.client.api.PulsarClient pulsarClient)	Create a builder that adapts the specified pulsar client.
static <T> DefaultReactivePulsarSenderFactory.Builder<T>	DefaultReactivePulsarSenderFactory.builderFor(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient)	Create a builder that uses the specified Reactive pulsar client.
DefaultReactivePulsarSenderFactory.Builder<T>	DefaultReactivePulsarSenderFactory.Builder.withDefaultConfigCustomizer(ReactiveMessageSenderBuilderCustomizer<T> customizer)	Provide a customizer to apply to the sender builder.
DefaultReactivePulsarSenderFactory.Builder<T>	DefaultReactivePulsarSenderFactory.Builder.withDefaultConfigCustomizers(List<ReactiveMessageSenderBuilderCustomizer<T>> customizers)	Provide an optional list of sender builder customizers to apply to the builder before creating the senders.
DefaultReactivePulsarSenderFactory.Builder<T>	DefaultReactivePulsarSenderFactory.Builder.withDefaultTopic(String defaultTopic)	Provide the default topic to use when one is not specified.
DefaultReactivePulsarSenderFactory.Builder<T>	DefaultReactivePulsarSenderFactory.Builder.withMessageSenderCache(org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache messageSenderCache)	Provide the message sender cache to use.
DefaultReactivePulsarSenderFactory.Builder<T>	DefaultReactivePulsarSenderFactory.Builder.withTopicResolver(TopicResolver topicResolver)	Provide the topic resolver to use.