Modifier and Type | Method and Description |
---|---|
static org.apache.pulsar.client.api.transaction.Transaction |
createTransaction(org.apache.pulsar.client.api.PulsarClient pulsarClient,
long timeoutMs)
Create transaction with given timeout millis.
|
static org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException |
unwrap(org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException e)
This is a bug in original
TransactionCoordinatorClientException.unwrap(Throwable)
method. |
public static org.apache.pulsar.client.api.transaction.Transaction createTransaction(org.apache.pulsar.client.api.PulsarClient pulsarClient, long timeoutMs)
public static org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException unwrap(org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException e)
TransactionCoordinatorClientException.unwrap(Throwable)
method. Pulsar wraps the ExecutionException
which hides the real execution exception.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.