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

Interface AsyncProducer<T>

Type Parameters:

T - the type of message values this producer sends

public interface AsyncProducer<T>

Asynchronous view of a Producer.

All operations return CompletableFuture and never block. Obtained via Producer.async().

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	close()	Close this producer asynchronously.
CompletableFuture<Void>	flush()	Flush all pending messages asynchronously.
AsyncMessageBuilder<T>	newMessage()	Create a message builder for advanced message construction.

Method Details

newMessage

AsyncMessageBuilder<T> newMessage()

Create a message builder for advanced message construction. Use AsyncMessageBuilder.send() as the terminal operation.

Returns:

a new AsyncMessageBuilder for configuring and sending a message

flush

CompletableFuture<Void> flush()

Flush all pending messages asynchronously.

Returns:

a CompletableFuture that completes when all pending messages have been flushed to the broker

close

CompletableFuture<Void> close()

Close this producer asynchronously.

Returns:

a CompletableFuture that completes when the producer has been closed and all resources have been released