azure-docs-sdk-java/docs-ref-autogen/com.azure.core.amqp.AmqpTra...

45 строки
4.1 KiB
YAML

### YamlMime:JavaType
uid: "com.azure.core.amqp.AmqpTransactionCoordinator"
fullName: "com.azure.core.amqp.AmqpTransactionCoordinator"
name: "AmqpTransactionCoordinator"
nameWithType: "AmqpTransactionCoordinator"
summary: "Provides an API to manage AMQP transaction on the message broker."
syntax: "public interface **AmqpTransactionCoordinator**"
methods:
- uid: "com.azure.core.amqp.AmqpTransactionCoordinator.declare()"
fullName: "com.azure.core.amqp.AmqpTransactionCoordinator.declare()"
name: "declare()"
nameWithType: "AmqpTransactionCoordinator.declare()"
summary: "This creates the transaction on the message broker."
modifiers:
- "abstract"
syntax: "public abstract Mono<AmqpTransaction> declare()"
desc: "This creates the transaction on the message broker. Successful completion of this API indicates that a transaction identifier has successfully been created on the message broker. Once a transaction has been created, it must be completed by using <xref uid=\"com.azure.core.amqp.AmqpTransactionCoordinator.discharge(com.azure.core.amqp.AmqpTransaction,boolean)\" data-throw-if-not-resolved=\"false\" data-raw-source=\"AmqpTransactionCoordinator#discharge(AmqpTransaction, boolean)\"></xref> API."
returns:
description: "the created transaction id represented by <xref uid=\"com.azure.core.amqp.AmqpTransaction\" data-throw-if-not-resolved=\"false\" data-raw-source=\"AmqpTransaction\"></xref>."
type: "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<xref href=\"com.azure.core.amqp.AmqpTransaction?alt=com.azure.core.amqp.AmqpTransaction&text=AmqpTransaction\" data-throw-if-not-resolved=\"False\" />&gt;"
- uid: "com.azure.core.amqp.AmqpTransactionCoordinator.discharge(com.azure.core.amqp.AmqpTransaction,boolean)"
fullName: "com.azure.core.amqp.AmqpTransactionCoordinator.discharge(AmqpTransaction transaction, boolean isCommit)"
name: "discharge(AmqpTransaction transaction, boolean isCommit)"
nameWithType: "AmqpTransactionCoordinator.discharge(AmqpTransaction transaction, boolean isCommit)"
summary: "This completes the transaction on the message broker."
modifiers:
- "abstract"
parameters:
- description: "that needs to be completed on the message broker."
name: "transaction"
type: "<xref href=\"com.azure.core.amqp.AmqpTransaction?alt=com.azure.core.amqp.AmqpTransaction&text=AmqpTransaction\" data-throw-if-not-resolved=\"False\" />"
- description: "this flag indicates that the operations associated with this transaction should commit or\n rollback."
name: "isCommit"
type: "<xref href=\"boolean?alt=boolean&text=boolean\" data-throw-if-not-resolved=\"False\" />"
syntax: "public abstract Mono<Void> discharge(AmqpTransaction transaction, boolean isCommit)"
desc: "This completes the transaction on the message broker. All the operations belonging to this transaction will either rollback or committed as one unit of work."
returns:
description: "a completable <xref uid=\"reactor.core.publisher.Mono\" data-throw-if-not-resolved=\"false\" data-raw-source=\"Mono\"></xref>."
type: "<a href=\"https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html\">Mono</a>&lt;<a href=\"https://docs.oracle.com/javase/8/docs/api/java/lang/Void.html\">Void</a>&gt;"
type: "interface"
desc: "Provides an API to manage AMQP transaction on the message broker. A transaction is used where two or more operations in the messaging broker are part of one unit of work. The transaction must ensure that all operations belonging to a given transaction either succeed or fail jointly. In general a transaction is involved with many operations on one message broker entity. Sometime a transaction can span over multiple message broker entities explained as follows.\n\nDistributed Transactions: A distributed transaction where operations spans over different message broker entities. For example an application receive from entity 'A' and sends to entity 'B' and 'C' and all these operations are part of one transaction."
metadata: {}
package: "com.azure.core.amqp"
artifact: com.azure:azure-core-amqp:2.9.9