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

Interface AsyncTransaction

public interface AsyncTransaction
Asynchronous view of a Transaction.

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

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletableFuture<Void>
    abort()
    Abort this transaction, discarding all produced messages and rolling back acknowledgments.
    CompletableFuture<Void>
    commit()
    Commit this transaction, making all produced messages visible and all acknowledgments durable.

  • Method Details

    • commit

      CompletableFuture<Void> commit()
      Commit this transaction, making all produced messages visible and all acknowledgments durable.
      Returns:
      a CompletableFuture that completes when the transaction has been successfully committed

    • abort

      CompletableFuture<Void> abort()
      Abort this transaction, discarding all produced messages and rolling back acknowledgments.
      Returns:
      a CompletableFuture that completes when the transaction has been successfully aborted