Interface Transaction

@Public
@Evolving
public interface Transaction

The class represents a transaction within Pulsar.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	Transaction.State

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	abort()	Abort the transaction.
CompletableFuture<Void>	commit()	Commit the transaction.
Transaction.State	getState()	Get transaction state.
TxnID	getTxnID()	Get TxnID of the transaction.

Method Details

commit

CompletableFuture<Void> commit()

Commit the transaction.

Returns:

the future represents the commit result.

abort

CompletableFuture<Void> abort()

Abort the transaction.

Returns:

the future represents the abort result.

getTxnID

TxnID getTxnID()

Get TxnID of the transaction.

Returns:

TxnID the txnID.

getState

Transaction.State getState()

Get transaction state.

Returns:

Transaction.State the state of the transaction.