Package org.apache.pulsar.client.api.v5.async

Interface AsyncMessageBuilder<T>

Type Parameters:

T - the type of the message value

All Superinterfaces:

MessageMetadata<T,AsyncMessageBuilder<T>>

public interface AsyncMessageBuilder<T>
extends MessageMetadata<T,AsyncMessageBuilder<T>>

Asynchronous message builder, obtained from AsyncProducer.newMessage().

Inherits all metadata setters from MessageMetadata and adds a non-blocking send() terminal operation.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<MessageId>	send()	Send the message asynchronously.

Methods inherited from interface org.apache.pulsar.client.api.v5.MessageMetadata

deliverAfter, deliverAt, eventTime, key, properties, property, replicationClusters, sequenceId, transaction, value

Method Details

send

CompletableFuture<MessageId> send()

Send the message asynchronously.

Returns:

a CompletableFuture that completes with the MessageId assigned to the published message by the broker