Uses of Class
org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException

Packages that use TransactionCoordinatorClientException

Package	Description
org.apache.pulsar.client.api.transaction	Pulsar transaction related API.

Uses of TransactionCoordinatorClientException in org.apache.pulsar.client.api.transaction

Subclasses of TransactionCoordinatorClientException in org.apache.pulsar.client.api.transaction

Modifier and Type	Class	Description
static class	TransactionCoordinatorClientException.CoordinatorClientStateException	Thrown when transaction coordinator with unexpected state.
static class	TransactionCoordinatorClientException.CoordinatorNotFoundException	Thrown when transaction coordinator not found in broker side.
static class	TransactionCoordinatorClientException.InvalidTxnStatusException	Thrown when transaction switch to a invalid status.
static class	TransactionCoordinatorClientException.MetaStoreHandlerNotExistsException	Thrown when transaction meta store handler not exists.
static class	TransactionCoordinatorClientException.MetaStoreHandlerNotReadyException	Thrown when send request to transaction meta store but the transaction meta store handler not ready.
static class	TransactionCoordinatorClientException.TransactionNotFoundException	Thrown when transaction not found in transaction coordinator.

Methods in org.apache.pulsar.client.api.transaction that return TransactionCoordinatorClientException

Modifier and Type	Method	Description
static TransactionCoordinatorClientException	TransactionCoordinatorClientException.unwrap(Throwable t)

Methods in org.apache.pulsar.client.api.transaction that throw TransactionCoordinatorClientException

Modifier and Type	Method	Description
void	TransactionCoordinatorClient.abort(TxnID txnID)	Abort txn.
void	TransactionCoordinatorClient.addPublishPartitionToTxn(TxnID txnID, List<String> partitions)	Add publish partition to txn.
void	TransactionCoordinatorClient.addSubscriptionToTxn(TxnID txnID, String topic, String subscription)	Add ack subscription to txn.
void	TransactionCoordinatorClient.commit(TxnID txnID)	Commit txn.
TxnID	TransactionCoordinatorClient.newTransaction()	Create a new transaction.
TxnID	TransactionCoordinatorClient.newTransaction(long timeout, TimeUnit unit)	Create a new transaction.
void	TransactionCoordinatorClient.start()	Start transaction meta store client.