ServiceBusTransactionContext Classe

Pacote:

com.azure.messaging.servicebus

Artefato Maven:

com.azure:azure-messaging-servicebus:7.17.0

• java.lang.Object
• • com.azure.messaging.servicebus.ServiceBusTransactionContext

public final class ServiceBusTransactionContext

Representa a transação no serviço. Esse objeto contém apenas a ID da transação. Operações de gerenciamento de transações como criar transação, reversão e operação de confirmação precisam ser feitas usando os clientes remetente ou receptor.

Uma transação atinge o tempo limite após 2 minutos. O temporizador da transação é iniciado quando a primeira operação na transação é iniciada.

Criando e usando uma transação

// This mono creates a transaction and caches the output value, so we can associate operations with the
 // transaction. It does not cache the value if it is an error or completes with no items, effectively retrying
 // the operation.
 Mono<ServiceBusTransactionContext> transactionContext = asyncReceiver.createTransaction()
     .cache(value -> Duration.ofMillis(Long.MAX_VALUE),
         error -> Duration.ZERO,
         () -> Duration.ZERO);

 // Dispose of the disposable to cancel the operation.
 Disposable disposable = transactionContext.flatMap(transaction -> {
     // Process messages and associate operations with the transaction.
     Mono<Void> operations = Mono.when(
         asyncReceiver.receiveDeferredMessage(sequenceNumber).flatMap(message ->
             asyncReceiver.complete(message, new CompleteOptions().setTransactionContext(transaction))),
         asyncReceiver.abandon(receivedMessage, new AbandonOptions().setTransactionContext(transaction)));

     // Finally, either commit or rollback the transaction once all the operations are associated with it.
     return operations.then(asyncReceiver.commitTransaction(transaction));
 }).subscribe(unused -> {
 }, error -> {
     System.err.println("Error occurred processing transaction: " + error);
 }, () -> {
     System.out.println("Completed transaction");
 });

Resumo do método

Modificador e tipo	Método e descrição
ByteBuffer	getTransactionId() Obtém a ID da transação.

Métodos herdados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalhes do método

getTransactionId

public ByteBuffer getTransactionId()

Obtém a ID da transação.

Returns:

ID da transação