Skip to main content
The Advanced Message Queueing Protocol (AMQP) connector allows you to integrate AMQP into your data flow by performing Produce and Consume actions on your data.

​
Key Capabilities

  • Bidirectional message queueing with produce and consume actions
  • Support for multiple authentication schemes (None, SASL Anonymous, SASL Plain)
  • TLS encryption support for secure connections
  • Flexible message value types including JSON composite data support
Follow the steps below to connect CData Arc to AMQP.

​
Establish a Connection

You must first establish a connection to AMQP through one of these two methods:
  • Add a AMQP connector to your flow. Then, in the settings pane, click Create next to the Connection drop-down list.
  • Open the CData Arc Settings page, then open the Connections tab. Click Add, select AMQP, and click Next.
  • The login process is only required the first time the connection is created.
  • Connections to AMQP can be re-used across multiple AMQP connectors.
After opening the connection dialogue, follow these steps:
  1. Enter the connection information:
    • Name — the static name of the connection.
    • Type — this is always set to AMQP.
    • Remote Host — the hostname or IP address of your AMQP remote host.
    • Remote Port — the port for your remote host connection.
    • Use TLS — whether to use TLS to encrypt the connection. Set this according to your AMQP configuration.
    • Container Id — (optional) the ID value for the container in your AMQP connection that you want to access.
    • Auth Scheme — the authentication scheme to use for the connection. Options are None, SASL Anonymous, and SASL Plain.
    If you select SASL Anonymous or SASL Plain authentication, enter the following information:
    • User — the username to use when connecting to AMQP.
    • Password — the password for the user.
  2. Click Test Connection to ensure that Arc can connect to AMQP with the provided information. If an error occurs, check all fields and try again.
  3. Click Add Connection to finalize the connection.

​
Connector Configuration

This section contains all of the configurable connector properties.

​
Settings Tab

​
Configuration

​
AMQP Message

JSON Composite Data Value Type
One Value Type option is JSON (Composite Data). The composite data JSON schema consists of type-value objects, which hold an AMQP typename and a value. The syntax for a type-value object is:
The following table provides a complete list of valid typenames, and describes how the associated values should be represented:
Typenames must be lowercase in order to be parsed correctly.

​
Advanced Tab

​
Other Settings

​
Proxy Settings

これらは、接続のルーティング先となるプロキシを識別し認証するための一連の設定です。デフォルトでは、このセクションはSecurity Settings ページのProxy Settings 部分にあるグローバル設定を使用します。チェックボックスをオフにすると、コネクタ固有の設定を指定できます。

設定説明
Proxy Typeプロキシベースのファイアウォールで使用されるプロトコル。
Proxy Hostプロキシベースのファイアウォールの名前またはIP アドレス。
Proxy PortプロキシベースのファイアウォールのTCP ポート。
Proxy Userプロキシベースのファイアウォールで認証するために使用するユーザー名。
Proxy Passwordプロキシベースのファイアウォールで認証するために使用するパスワード。
Authentication SchemeデフォルトのNone のままにするか、次の認証スキームのいずれかを選択します：Basic、Digest、Proprietary、またはNTLM。

​
Message

Message 設定は、コネクタがメッセージを検索する方法と、処理後にメッセージを管理する方法を決定します。

Note： 以下の設定は非推奨となり、デフォルトで非表示になっています。以前に有効化またはデフォルト以外の値に設定されていたコネクタにのみ表示されます。処理済みファイルのコピーを保持するには、フロー内のコネクタを右クリックし、成功パスを表示を選択して、成功パスをFile コネクタに接続してください。

設定説明
Sent フォルダに保存（非推奨）コネクタが処理したファイルをSent フォルダにコピーします。デフォルトで無効です。Sent フォルダに保存されたファイルは保存データの暗号化の対象外です。
Sent フォルダのスキーム（非推奨）選択した時間間隔でSent フォルダ内のファイルをグループ化します。Sent フォルダに保存が有効な場合のみ適用されます。

​
Logging

ログの作成と保存を制御する設定です。

設定説明
Log Levelコネクタが生成するログの詳細度です。サポートを依頼する際は、これをDebug に設定してください。
Log Subfolder Scheme選択した間隔に従って、コネクタがLogs フォルダ内のファイルをグループ化するよう指示します。Weekly オプション（デフォルト）は、コネクタが毎週新しいサブフォルダを作成し、その週のすべてのログをそのフォルダに保存するよう指示します。この設定を空白のままにすると、コネクタはすべてのログをLogs フォルダに直接保存します。多数のトランザクションを処理するコネクタでは、サブフォルダを使用することでログを整理しやすくなり、パフォーマンスが向上します。
Log Messages処理したファイルのログエントリにファイル自体のコピーを含めるには、これをオンにします。これを無効にすると、Transactions タブからファイルのコピーをダウンロードできなくなる場合があります。

​
Miscellaneous

Miscellaneous 設定は、特定のユースケース向けの設定です。

設定説明
Other Settings非表示のコネクタ設定をセミコロン区切りのリストで設定できます（例：setting1=value1;setting2=value2）。通常のコネクタのユースケースや機能では、これらの設定の使用は必要ありません。

​
Automation Tab

​
Automation Settings

Settings related to the automatic processing of files by the connector.

​
Performance

コネクタへのリソースの割り当てに関する設定です。

設定説明
Max Workersこのコネクタでファイルを処理するためにスレッドプールから消費されるワーカースレッドの最大数です。設定すると、Advanced Settings ページのPerformance Settings 部分にあるデフォルト設定が上書きされます。
Max Filesコネクタに割り当てられた各スレッドが送信するファイルの最大数です。設定すると、Advanced Settings ページのPerformance Settings 部分にあるデフォルト設定が上書きされます。

​
Alerts Tab

​
SLAs Tab

​
ログタブ

ログタブには、このコネクタが生成したサービスログが一覧表示されます。各行はログファイルを表し、更新日時、ファイル名、サイズ、ステータスが表示されます。特定のログを検索するには検索バーまたはステータスフィルタを使用し、ファイル名をクリックしてプレビューまたはダウンロードするか、すべてのログをダウンロードをクリックしてすべてのログを単一のzipファイルとしてダウンロードします。

​
Select an Action

After establishing a connection to AMQP, you must choose the action that the AMQP connector will perform. The table below outlines each action and where it belongs in a CData Arc flow:

​
Produce

The Produce action sends input data to your AMQP connection. This data can come from other connectors or from files that you manually upload to the Transactions tab of the AMQP connector. In some AMQP configurations, you can set the value of the Target field to the address of the node that should act as the receiver. This might not be necessary in all configurations.

​
Consume

The Consume action checks for messages in the AMQP queue. Data processed through the Consume connector goes to the Transactions tab and travels down to the next steps of the Arc flow. In some AMQP configurations, you can set the value of the Target field to the address of the node that the connector should receive data from. This might not be necessary in all configurations.

​
Macros

​
Examples