Package org.springframework.pulsar.reactive.core

Interface ReactivePulsarOperations.SendOneMessageBuilder<T>

All Superinterfaces:

ReactivePulsarOperations.SendMessageBuilder<ReactivePulsarOperations.SendOneMessageBuilder<T>,T>

Enclosing interface:

ReactivePulsarOperations<T>

public static non-sealed interface ReactivePulsarOperations.SendOneMessageBuilder<T>
extends ReactivePulsarOperations.SendMessageBuilder<ReactivePulsarOperations.SendOneMessageBuilder<T>,T>

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<org.apache.pulsar.client.api.MessageId>	send()	Send the message in a reactive manner using the configured specification.
ReactivePulsarOperations.SendOneMessageBuilder<T>	withMessageCustomizer(MessageSpecBuilderCustomizer<T> customizer)	Specifies the message customizer to use to further configure the message.

Methods inherited from interface org.springframework.pulsar.reactive.core.ReactivePulsarOperations.SendMessageBuilder

withSchema, withSenderCustomizer, withTopic

Method Details

withMessageCustomizer

ReactivePulsarOperations.SendOneMessageBuilder<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

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