Package org.springframework.pulsar.reactive.core

Interface ReactivePulsarOperations.SendMessageBuilder<T>

Type Parameters:
T - the message payload type
All Known Implementing Classes:
ReactivePulsarTemplate.SendMessageBuilderImpl
Enclosing interface:
ReactivePulsarOperations<T>
public static interface ReactivePulsarOperations.SendMessageBuilder<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

      ReactivePulsarOperations.SendMessageBuilder<T> 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

    • withMessageCustomizer

      ReactivePulsarOperations.SendMessageBuilder<T> withMessageCustomizer(MessageSpecBuilderCustomizer<T> customizer)
      Specifies the message customizer to use to further configure the message.
      Parameters:
      customizer - the message customizer
      Returns:
      the current builder with the message customizer specified

    • withSenderCustomizer

      ReactivePulsarOperations.SendMessageBuilder<T> 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

    • send

      reactor.core.publisher.Mono<org.apache.pulsar.client.api.MessageId> send()
      Send the message in a reactive manner using the configured specification.
      Returns:
      the id assigned by the broker to the published message