Package org.springframework.pulsar.reactive.core

Interface ReactivePulsarOperations.SendMessageBuilder<O,T>

Type Parameters:
O - the builder type
T - the message payload type
All Known Subinterfaces:
ReactivePulsarOperations.SendManyMessageBuilder<T>, ReactivePulsarOperations.SendOneMessageBuilder<T>
Enclosing interface:
ReactivePulsarOperations<T>
public static sealed interface ReactivePulsarOperations.SendMessageBuilder<O,T> permits ReactivePulsarOperations.SendOneMessageBuilder<T>, ReactivePulsarOperations.SendManyMessageBuilder<T>
Builder that can be used to configure and send a message. Provides more options than the send methods provided by ReactivePulsarOperations.

  • Method Details

    • withTopic

      O withTopic(String topic)
      Specify the topic to send the message to.
      Parameters:
      topic - the destination topic
      Returns:
      the current builder with the destination topic specified

    • withSchema

      O withSchema(org.apache.pulsar.client.api.Schema<T> schema)
      Specify the schema to use when sending the message.
      Parameters:
      schema - the schema to use
      Returns:
      the current builder with the schema specified

    • withSenderCustomizer

      O withSenderCustomizer(ReactiveMessageSenderBuilderCustomizer<T> customizer)
      Specifies the customizer to use to further configure the reactive sender builder.
      Parameters:
      customizer - the reactive sender builder customizer
      Returns:
      the current builder with the reactive sender builder customizer specified