# cMQConnectionFactory

MQサーバーに接続するための設定パラメーターのセットをカプセル化します。接続は、ルート内の複数のコンポーネント(cAMQP、cJMS、cMQTT、cRabbitMQ、cWMQ)によって呼び出すことができます。

## cMQConnectionFactoryの標準プロパティ

これらのプロパティは、標準ジョブのフレームワークで実行されているcMQConnectionFactoryを設定するために使われます。

標準のcMQConnectionFactoryコンポーネントは、Connectivityファミリーに属しています。

## 基本設定

| プロパティ | 説明 |
| --- | --- |
| [MQ server] (MQサーバー) | ActiveMQ、RabbitMQ、WebSphere MQ Jms、WebSphere MQ Native、AMQP 1.0、MQTT、Customizedの中からMQサーバーを選択します。<br><br>情報メモ注: RabbitMQオプションは、Talendが提供する8.0.1-R2025-02以降のTalend Studioマンスリーアップデートをインストール済みである場合のみ利用できます。詳細は、管理者にお問い合わせください。<br><br>WebSphere MQネイティブサーバーへの接続は、プロパティファイル内からでも設定できます。詳細は、[プロパティファイルでWebSphere MQネイティブサーバーへの接続を設定](https://help.qlik.com/talend/ja-JP/components/8.0/mediation-amqp/cmqconnectionfactory-cmqconnectionfactory-configuring-connection-to-websphere-mq-native-server-in-properties-file)をご覧ください。<br><br>WebSphere MQへの接続の詳細は、[Connecting to Websphere MQ](https://help.qlik.com/talend/r/en-US/8.0/esb-service-developer-guide/connecting-to-websphere-mq)をご覧ください。 |
| [Use Transaction] (トランザクションを使用) (ActiveMQ、WebSphere MQ Jms、[Customized] (カスタマイズ)のみ) | MQサーバーからのメッセージを消費するルートでローカルトランザクションを有効にする場合は、このチェックボックスをオンにします。ルートで例外が発生した場合、メッセージブローカーのメッセージは、再配信ポリシー用に設定されたmaximumRedeliveriesの後で配信不能キューに送信され、ルートによって消費されません。詳細は、http://camel.apache.org/transactional-client.htmlをご覧ください。 |
| [Broker URI] (ブローカーURI) (ActiveMQのみ) | メッセージブローカーのURIを入力します。<br><br>ルート内メッセージ処理の場合は、デフォルトのURIであるvm://localhost?broker.persistent=false for ActiveMQを使うだけで十分です。<br><br>情報メモ警告:<br><br>[Broker URI] (ブローカーURI)パラメーターに"{{activemq\_url}}"を設定しようとすると、次のエラーメッセージが表示される場合があります。<br><br>```<br>Invalid broker URI: {{activemq_url}}<br>```<br><br>プロパティコンポーネントを設定すれば、大半のTalendコンポーネントでCamelプロパティ構文{{...}}を直接使用できるようになります。ただし、いくつかの例外があります。cMQConnectionFactoryコンポーネントは、{{...}}構文を直接使用できない例外の1つです。<br><br>"{{activemq\_url}}"を使う代わりに、次に示すようにCamel resolvePropertyPlaceholdersメソッドを呼び出します。<br><br>```<br>camelContext.resolvePropertyPlaceholders("{{activemq_url}}")<br>``` |
| [HTTP Transport] (HTTP転送) (ActiveMQのみ) | ActiveMQブローカーへのHTTPベースの接続を有効にする場合は、このチェックボックスをオンにします。 |
| [Use PooledConnectionFactory] (PooledConnectionFactoryを使用) (ActiveMQのみ) | このチェックボックスをオンにして、PooledConnectionFactoryを使用します。 |
| [Max Connections] (最大接続数) (ActiveMQのみ) | PooledConnectionFactoryの最大接続数を指定します。このフィールドは、[Use PooledConnectionFactory] (PooledConnectionFactoryを使用)チェックボックスがオンの場合のみ利用できます。 |
| [Max Active] (最大稼動) (ActiveMQのみ) | 接続ごとの最大セッション数を指定します。このフィールドは、[Use PooledConnectionFactory] (PooledConnectionFactoryを使用)チェックボックスがオンの場合のみ利用できます。 |
| [Idle Timeout (in ms)] (アイドルタイムアウト(ミリ秒)) (ActiveMQのみ) | 接続が切断されるまでの最大待機時間(ミリ秒単位)を指定します。このフィールドは、[Use PooledConnectionFactory] (PooledConnectionFactoryを使用)チェックボックスがオンの場合のみ利用できます。 |
| [Expiry Timeout (in ms)] (有効期限タイムアウト(ミリ秒)) (ActiveMQのみ) | 初めて使用してから接続が切断されるまでの時間(ミリ秒単位)を指定します。デフォルト値は60000です。0を指定すると有効期限は無効になります。このフィールドは、[Use PooledConnectionFactory] (PooledConnectionFactoryを使用)チェックボックスがオンの場合のみ利用できます。 |
| [Host Name] (ホスト名) (RabbitMQ、WebSphere MQ Jms、WebSphere MQ Native、AMQP 1.0、MQTTのみ) | IBM WebSphere MQサーバーまたはMQTTブローカーが実行されているホストの名前またはIPアドレスを入力します。WebSphere MQ Jms、WebSphere MQ Native、AMQP 1.0の場合、デフォルトは"localhost"です。MQTTの場合、デフォルトは 127.0.0.1です。<br><br>AMQP 1.0の場合、[Host Name] (ホスト名)には、標準的な単一のIPアドレスかホスト名、または"failover:(amqp://localhost:5672)"のようなフェイルオーバーURLのいずれかを設定できます。 |
| [Port] (ポート) (RabbitMQ、WebSphere MQ Jms、WebSphere MQ Native、AMQP 1.0、MQTTのみ) | MQサーバーのポートを入力します。<br><br><ul> <li><span>WebSphere MQ Jms</span>、<span>WebSphere MQ Native</span>、および<kbd>AMQP 1414</kbd>の場合、デフォルトはlocalhostです。</li> <li><span>AMQP 1.0</span>の場合、デフォルトは<kbd>5672</kbd>です。<span>[Host Name] (ホスト名)</span>がフェイルオーバーのURLであれば、ポートの値は無視されます。</li> <li><span>MQTT</span>の場合、デフォルトは<kbd>1883</kbd>です。</li> </ul> |
| [Virtual Host] (仮想ホスト) (RabbitMQのみ) | メッセージの公開や受信で使用する仮想ホストを指定します。<br><br>情報メモ注: このオプションは、Talendが提供する8.0.1-R2025-02以降のTalend Studioマンスリーアップデートをインストール済みである場合のみ利用できます。詳細は、管理者にお問い合わせください。 |
| [Transport Type] (転送タイプ) (WebSphere MQ Jmsのみ) | IBM WebSphere MQサーバーとWebSphere MQブローカーの間のメッセージ転送のタイプを、[Bindings] (バインド)、[Bindings then Client] (バインドとクライアント)、[Client] (クライアント)から選択します。 |
| [Queue Manager] (キューマネージャー) (WebSphere MQ Jmsのみ) | キューマネージャーの名前を入力するか、IBM WebSphere MQサーバーの名前を指定してキューマネージャーを検索します。 |
| [Channel] (チャネル) (WebSphere MQ Jmsおよび[WebSphere MQ Native] (WebSphere MQネイティブ)のみ) | 接続を確立するチャネルの名前を指定します。WebSphere MQ Jmsの場合、デフォルトはSYSTEM.DEF.SVRCONNです。[WebSphere MQ Native] (WebSphere MQネイティブ)の場合、デフォルトはchannel.nameです。 |
| [Name] (名前) ([WebSphere MQ Native] (WebSphere MQネイティブ)のみ) | 接続を確立するキューマネージャーの名前を指定します。 |
| [Use Authentication] (ユーザー認証) (ActiveMQ、WebSphere MQ Jms、WebSphere MQ Native、AMQP 1.0、MQTTのみ) | このチェックボックスをオンにし、MQサーバーのユーザー名とパスワードを入力して、アクセス許可を検証します。パスワードを入力するには、パスワードフィールドの横にある[...]ボタンをクリックし、ポップアップダイアログボックスにパスワードを二重引用符の間に入力し、[OK] をクリックして設定を保存します。[WebSphere MQ Native] (WebSphere MQネイティブ)サーバーの場合は、文字の数値順序を定義するCCSID (コード化文字セット識別子)を追加で提供します。CCSIDの詳細は、http://www-01.ibm.com/software/globalization/cdra/appendix\_c.htmlをご覧ください。 |
| [Dependencies] (依存項目) (WebSphere MQ Jms、[WebSphere MQ Native] (WebSphere MQネイティブ)、[Customized] (カスタマイズ)のみ) | MQブローカーが必要とする追加のライブラリーを指定します。 |
| [Use SSL] (SSLを使用) (AMQP 1.0およびMQTTのみ) | SSLプロトコルを介してMQサーバーに接続する場合は、このチェックボックスをオンにします。MQTTの場合は、MQサーバーが信頼する証明書のリストを含むTrustStoreファイルを指定し、TrustStoreデータの整合性をチェックするために使うパスワードを入力します。 |
| [Auto Reconnect] (自動再接続) (MQTTのみ) | 接続が失われた時にサーバーに再接続する場合は、このチェックボックスをオンにします。 |
| [Connection timeout] (接続タイムアウト) (MQTTのみ) | クライアントがMQTTサーバーとのネットワーク接続が確立されるまでの最大待機時間(秒単位)です。デフォルトは30です。 |
| [Max Reconnect Delay] (再接続最大遅延) (MQTTのみ) | 初期接続または失敗した接続を再確立する試行間のミリ秒単位の最大時間。デフォルトは128000です。 |
| [MQTT version] (MQTTバージョン) (MQTTのみ) | 接続するMQTTのバージョンを選択します。デフォルトは3.1.1です。 |
| [Quality of Service] (サービスの品質) (MQTTのみ) | メッセージ交換に使うMQTTサービス品質。AtMostOnce、AtLeastOnce、ExactlyOnceのいずれかです。 |

## 使用方法

| 使用方法のガイダンス | 説明 |
| --- | --- |
| **使用ルール** | cMQConnectionFactoryは、入力コンポーネントや出力コンポーネントがリンクされていないルートに直接追加できます。 |
| 制限事項 | ライセンスの互換性の問題のため、このコンポーネントの使用に必要な1つ以上のJARが提供されていません。この特定のコンポーネントに不足しているJARをインストールするには、Component (コンポーネント)タブビューの[Install] (インストール)ボタンをクリックします。Talend StudioのIntegrationパースペクティブにある[Modules] (モジュール)タブでも、不足しているすべてのJARを簡単に見つけて追加できます。詳細は、[外部モジュールをインストール](https://help.qlik.com/talend/r/ja-JP/8.0/studio-user-guide/installing-external-modules)をご覧ください。<br><br>[WebSphere MQ Native] (WebSphere MQネイティブ)サーバーを使う場合は、com.ibm.mq.jar、com.ibm.mq.commonservices.jar、com.ibm.mq.headers.jar、com.ibm.mq.jmqi.jar、connector.jarをIBM Webサイトからダウンロードし、[Dependencies] (依存項目)リストに追加する必要があります。 |

**関連概念**

* [RabbitMQサービスに対してメッセージを送受信](https://help.qlik.com/talend/ja-JP/mediation-components/8.0/mediation-jms/sending-messages-to-and-receiving-messages-from-rabbitmq-service)