Package org.springframework.pulsar.reactive.core

Interface ReactivePulsarOperations.SendManyMessageBuilder<T>

All Superinterfaces:

ReactivePulsarOperations.SendMessageBuilder<ReactivePulsarOperations.SendManyMessageBuilder<T>,T>

Enclosing interface:

ReactivePulsarOperations<T>

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

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<org.apache.pulsar.reactive.client.api.MessageSendResult<T>>	send()	Send the messages in a reactive manner using the configured specification.

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

withSchema, withSenderCustomizer, withTopic

Method Details

send

reactor.core.publisher.Flux<org.apache.pulsar.reactive.client.api.MessageSendResult<T>> send()

Send the messages in a reactive manner using the configured specification.

Returns:

the ids assigned by the broker to the published messages in the same order as they were sent