Package org.springframework.pulsar.reactive.core

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

    Constructors
    Constructor
    Description
    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(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 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.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • 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: ReactivePulsarSenderFactory
      Create a reactive message sender.
      Specified by:
      createSender in interface ReactivePulsarSenderFactory<T>
      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

      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: ReactivePulsarSenderFactory
      Create a reactive message sender.
      Specified by:
      createSender in interface ReactivePulsarSenderFactory<T>
      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

      public org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec getReactiveMessageSenderSpec()
      Description copied from interface: ReactivePulsarSenderFactory
      Return the ReactiveMessageSenderSpec to use when creating reactive senders.
      Specified by:
      getReactiveMessageSenderSpec in interface ReactivePulsarSenderFactory<T>
      Returns:
      the ReactiveMessageSenderSpec