Class DefaultReactivePulsarSenderFactory<T>
java.lang.Object
org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory<T>
- Type Parameters:
T- reactive sender type.
- All Implemented Interfaces:
ReactivePulsarSenderFactory<T>
public class DefaultReactivePulsarSenderFactory<T>
extends Object
implements ReactivePulsarSenderFactory<T>
Default implementation of
ReactivePulsarSenderFactory.- Author:
- Christophe Bornet
-
Constructor Summary
ConstructorsConstructorDescriptionDefaultReactivePulsarSenderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec reactiveMessageSenderSpec, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache reactiveMessageSenderCache) DefaultReactivePulsarSenderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec reactiveMessageSenderSpec, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache reactiveMessageSenderCache) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageSender<T>createSender(String topic, org.apache.pulsar.client.api.Schema<T> schema) Create a reactive message sender.org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T>createSender(String topic, org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageSenderBuilderCustomizer<T>> customizers) Create a reactive message sender.org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpecReturn the ReactiveMessageSenderSpec to use when creating reactive senders.
-
Constructor Details
-
DefaultReactivePulsarSenderFactory
public DefaultReactivePulsarSenderFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec reactiveMessageSenderSpec, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache reactiveMessageSenderCache) -
DefaultReactivePulsarSenderFactory
public DefaultReactivePulsarSenderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec reactiveMessageSenderSpec, org.apache.pulsar.reactive.client.api.ReactiveMessageSenderCache reactiveMessageSenderCache)
-
-
Method Details
-
createSender
public org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T> createSender(String topic, org.apache.pulsar.client.api.Schema<T> schema) Description copied from interface:ReactivePulsarSenderFactoryCreate a reactive message sender.- Specified by:
createSenderin interfaceReactivePulsarSenderFactory<T>- Parameters:
topic- the topic the reactive message sender will send messages to ornullto use the default topicschema- the schema of the messages to be sent- Returns:
- the reactive message sender
-
createSender
public org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T> createSender(String topic, org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageSenderBuilderCustomizer<T>> customizers) Description copied from interface:ReactivePulsarSenderFactoryCreate a reactive message sender.- Specified by:
createSenderin interfaceReactivePulsarSenderFactory<T>- Parameters:
topic- the topic the reactive message sender will send messages to ornullto use the default topicschema- the schema of the messages to be sentcustomizers- the optional list of customizers to apply to the reactive message sender builder- Returns:
- the reactive message sender
-
getReactiveMessageSenderSpec
public org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec getReactiveMessageSenderSpec()Description copied from interface:ReactivePulsarSenderFactoryReturn the ReactiveMessageSenderSpec to use when creating reactive senders.- Specified by:
getReactiveMessageSenderSpecin interfaceReactivePulsarSenderFactory<T>- Returns:
- the ReactiveMessageSenderSpec
-