Package org.springframework.pulsar.reactive.core

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

  • Method Summary

    Modifier and Type
    Method
    Description
    org.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.ReactiveMessageSenderSpec
    getReactiveMessageSenderSpec()
    Return the ReactiveMessageSenderSpec to use when creating reactive senders.

  • Method Details

    • createSender

      org.apache.pulsar.reactive.client.api.ReactiveMessageSender<T> createSender(String topic, org.apache.pulsar.client.api.Schema<T> schema)
      Create a reactive message sender.
      Parameters:
      topic - the topic the reactive message sender will 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(String topic, org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageSenderBuilderCustomizer<T>> customizers)
      Create a reactive message sender.
      Parameters:
      topic - the topic the reactive message sender will send messages to or null to use the default topic
      schema - the schema of the messages to be sent
      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