---
schema_version: "1"
id: a50ec0b4ab92bf14d8fe440191ac2629a16278db0930d5753da003f6aa086cf5
title: IBM MQ でのトランザクション処理
collection: mulesoft
version: current
locale: ja-jp
portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/ibm-mq-connector/1.7/ibm-mq-transactions.md
canonical_url: https://docs.mulesoft.com/jp/ibm-mq-connector/1.7/ibm-mq-transactions
source_site: docs.mulesoft.com
content_type: documentation
content_hash: 97c511d9f551b733291805e3881cf5e2b54186f20470045621cc605e91cf4f2c
description: MuleSoft Documentation Site
release: "1.7"
latest: true
---
# IBM MQ でのトランザクション処理

IBM MQ のトランザクション接続を使用すると、一連の操作をトランザクションがコミットされたときにまとめて実行するように設定できます。主な 2 つのシナリオは次のとおりです。

- トランザクションの一環でメッセージをパブリッシュする: パブリッシュすると、メッセージはトランザクションがコミットされた後で宛先に送信されます。 何らかの理由でトランザクションが失敗してロールバックが発生すると、メッセージは送信されません。
- トランザクションの一環でメッセージをコンシュームする: リスナーまたはコンシューマーによってコンシュームされたメッセージは、トランザクションがコミットされてはじめて肯定応答され、トランザクションがロールバックされた場合は、再配信のために宛先に戻されます。

IBM MQ Connector は、Mule の transactionalAction 設定を使用して、トランザクションとしての操作の実行をサポートしています。

操作をトランザクションの一部として実行するには、次の 2 つのオプションがあります。

## [](#新規メッセージのトランザクションセッションでの処理)新規メッセージのトランザクションセッションでの処理

IBM MQ の ​`On New Message`​ リスナーでトランザクションセッションを使用してメッセージをディスパッチしたい場合は、transactionalAction を ​ALWAYS\_BEGIN​ に設定します。

```xml
<ibm-mq:listener
     config-ref="IBM_MQ_Config"
     destination="${originQueue}"
     transactionalAction="ALWAYS_BEGIN"/>
```

この設定により、それぞれの新規メッセージはトランザクションで処理され、このトランザクションはすべてのフローのコンポーネントに伝播されて、フローの実行が正常に完了した時点でコミットされます。 フローがエラーで完了した場合は、トランザクションはロールバックされます。

**注意:**​ デフォルトでは、フローの他のコンポーネントは、リスナーが作成したトランザクションには加わりません。他の操作をリスナーのトランザクションで実行するには、​ALWAYS\_JOIN​ または ​JOIN\_IF\_POSSIBLE​ でそれらを宣言する必要があります。

## [](#トランザクションの一部としての操作の実行)トランザクションの一部としての操作の実行

パブリッシュやコンシュームなどの操作をトランザクションの一環として実行するには、transactionalAction を ​ALWAYS\_JOIN​ または ​JOIN\_IF\_POSSIBLE​ に設定します。

このように設定した操作は、リスナーが開始するトランザクションの一部となります。

```xml
<flow name="joiningToListenerTransaction">
    <ibm-mq:listener config-ref="IBM_MQ_Config"
      destination="${originQueue}"
      transactionalAction="ALWAYS_BEGIN"/>
    <ibm-mq:publish config-ref="IBM_MQ_Config"
      destination="#[attributes.properties.userProperties.redirectDestination]"
      transactionalAction="JOIN_IF_POSSIBLE"/>
    <ibm-mq:consume config-ref="IBM_MQ_Config"
      destination="#[attributes.properties.userProperties.callbackDestination]"
      transactionalAction="JOIN_IF_POSSIBLE"/>
</flow>
```

スコープ付きトランザクションの一部として実行する場合は次のように設定します。

```xml
<flow name="nonTxPublishMustNotJoinCurrentTx">
    <http:listener config-ref="HTTP_Config" path="/orders"/>
    <try transactionalAction="ALWAYS_BEGIN">
        <ibm-mq:publish config-ref="config"
	destination="${billingService}"
	transactionalAction="ALWAYS_JOIN"/>
        <ibm-mq:publish config-ref="config"
	destination="${shipmentService}"
	transactionalAction="ALWAYS_JOIN"/>
        <ibm-mq:publish-consume config-ref="IBM_MQ_Config"
	destination="${invoicesVerificationService}"/>
        <validation:is-true expression="#[payload]"/>
    </try>
</flow>
```

## [](#xa-トランザクション)XA トランザクション

IBM MQ Connector では、XA トランザクションの作成と結合をサポートしており、複数リソースのトランザクションに関与することができます。これにより、IBM MQ の他の接続や、Database Connector や VM Connector などの接続を使用してトランザクションのアクションを実行することもできます。

<table><tbody><tr><td class="icon"><i class="fa icon-note" title="Note"></i></td><td class="content">IBM MQ Connector では、IBM MQ ドライバーの制限により、ネストされた XA トランザクションはサポートされません。ネストされたトランザクションを操作すると、外側のトランザクションが停止され、内側のトランザクションが終了した後に再開されます。このエラーが発生するのは、ドライバーの実装が原因で、外側のトランザクションが再開された場合です。</td></tr></tbody></table>

XA トランザクションを有効にするには:

1. `enableXa`​ を true に設定して、XA 対応接続を作成します。
    
    ```xml
    <ibm-mq:config name="IBM_MQ_Config" >
    		<ibm-mq:connection enableXa="true" >
    			<ibm-mq:connection-mode >
    				<ibm-mq:client host="0.0.0.0" queueManager="QM1" />
    			</ibm-mq:connection-mode>
    		</ibm-mq:connection>
    	</ibm-mq:config>
    ```
2. transactionType を XA に設定して、XA トランザクションを作成するように設定します。
    
    ```xml
    <flow name="joiningToListenerTransaction">
        <ibm-mq:listener config-ref="IBM_MQ_Config"
        destination="${originQueue}"
        transactionalAction="ALWAYS_BEGIN"
        transactionType="XA"/>
        <ibm-mq:publish config-ref="IBM_MQ_Config"
        destination="#[attributes.properties.userProperties.redirectDestination]"
        transactionalAction="JOIN_IF_POSSIBLE"/>
        <ibm-mq:consume config-ref="IBM_MQ_Config"
        destination="#[attributes.properties.userProperties.callbackDestination]"
        transactionalAction="JOIN_IF_POSSIBLE"/>
    </flow>
    ```
    
    スコープ付きトランザクションの一部として実行する場合は次のように設定します。
    
    ```xml
    <flow name="nonTxPublishMustNotJoinCurrentTx">
        <http:listener config-ref="HTTP_Config" path="/orders"/>
        <try transactionalAction="ALWAYS_BEGIN" transactionType="XA">
            <ibm-mq:publish config-ref="config"
    	destination="${billingService}"
    	transactionalAction="ALWAYS_JOIN"/>
            <ibm-mq:publish config-ref="config"
    	destination="${shipmentService}"
    	transactionalAction="ALWAYS_JOIN"/>
    
            <ibm-mq:publish-consume config-ref="IBM_MQ_Config"
    	destination="${invoicesVerificationService}"/>
            <validation:is-true expression="#[payload]"/>
        </try>
    </flow>
    ```