Interface ReactivePulsarSenderFactory<T>

Type Parameters:
T - reactive message sender payload type
All Known Implementing Classes:
DefaultReactivePulsarSenderFactory

public interface ReactivePulsarSenderFactory<T>
The strategy to create a ReactiveMessageSender instance(s).
Author:
Christophe Bornet, Chris Bono
  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T>
    createSender(org.apache.pulsar.client.api.Schema<T> schema, String topic)
    Create a reactive message sender.
    org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T>
    createSender(org.apache.pulsar.client.api.Schema<T> schema, String topic, List<ReactiveMessageSenderBuilderCustomizer<T>> customizers)
    Create a reactive message sender.
    org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T>
    createSender(org.apache.pulsar.client.api.Schema<T> schema, String topic, ReactiveMessageSenderBuilderCustomizer<T> customizer)
    Create a reactive message sender.
    org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec
    Return the ReactiveMessageSenderSpec to use when creating reactive senders.
  • Method Details

    • createSender

      org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T> createSender(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic)
      Create a reactive message sender.
      Parameters:
      topic - the topic to send messages to or null to use the default topic
      schema - the schema of the messages to be sent
      Returns:
      the reactive message sender
    • createSender

      org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T> createSender(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable ReactiveMessageSenderBuilderCustomizer<T> customizer)
      Create a reactive message sender.
      Parameters:
      schema - the schema of the messages to be sent
      topic - the topic to send messages to or null to use the default topic
      customizer - the optional customizer to apply to the reactive message sender builder
      Returns:
      the reactive message sender
    • createSender

      org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T> createSender(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable List<ReactiveMessageSenderBuilderCustomizer<T>> customizers)
      Create a reactive message sender.
      Parameters:
      schema - the schema of the messages to be sent
      topic - the topic to send messages to or null to use the default topic
      customizers - the optional list of customizers to apply to the reactive message sender builder
      Returns:
      the reactive message sender
    • getReactiveMessageSenderSpec

      org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec getReactiveMessageSenderSpec()
      Return the ReactiveMessageSenderSpec to use when creating reactive senders.
      Returns:
      the ReactiveMessageSenderSpec