AMQP Connector リファレンス

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

String (文字列)

メッセージにエンコードが指定されていない場合に使用するメッセージ本文のデフォルトエンコード。

String (文字列)

メッセージにエンコードが指定されていない場合に使用するメッセージ本文のデフォルトコンテンツタイプ。

/

String (文字列)

代替定義が指定されている場合にその定義に従って存在しないキューを作成するかどうか。

true

String (文字列)

代替定義が指定されている場合にその定義に従って存在しないエクスチェンジを作成するかどうか。

true

String (文字列)

接続先のブローカーのホスト。

x

Number (数値)

接続先の AMQP ブローカーのポート。

String (文字列)

認証のログイン情報を提供するときに使用するユーザー名。

x

String (文字列)

認証のログイン情報を提供するときに使用するパスワード。

x

Boolean (ブール)

TLS が必要かどうか。指定しない場合、AMQP 接続のデフォルトが使用されます。

false

Boolean (ブール)

ハートビートタイムアウト。ハートビートフレームは、タイムアウトの約 1/2 の間隔で送信されます。(v1.2.0 以降)

60

Enumeration (列挙)。次のいずれかになります。

ハンドシェイクタイムアウト AMQP 接続ソケット設定の時間単位。(v1.5.0 以降)

MILLISECONDS

Integer (整数)

基盤となる AMQP Connector に設定する AMQP 0.9.1 タイムアウト。(v1.5.0 以降)

AMQP クライアントによるデフォルト (10000 ミリ秒)

List of Fallback Addresses (host, port) (代替アドレスのリスト (ホスト、ポート))

メインブローカーへの接続に失敗した場合に接続を試行するブローカーノードのアドレス。(v1.3.0 以降)

代替アドレスなし

Enumeration (列挙)。次のいずれかになります。

メッセージをコンシュームするときに使用する ConsumerAckMode。メッセージソースレベルで上書きできます。

IMMEDIATE

Boolean (ブール)

true​ に設定されている場合、サーバーはメッセージをパブリッシュした接続にメッセージを送信しません。

false

Boolean (ブール)

コネクタで排他的なコンシューマーのみを作成する必要がある場合に ​true​ に設定します。つまり、作成されたコンシューマーのみがキューにアクセスできます。

false

Integer (整数)

AMQP メッセージを受信するためにメッセージソースによって実行されるコンシューマーの数。各コンシューマーでチャネルが作成されます。

4

Enumeration (列挙)。次のいずれかになります。

AMQP ブローカーにパブリッシュするときに使用する配信モード。

PERSISTENT

Integer (整数)

AMQP ブローカーにパブリッシュするときに使用する優先度。

0

Boolean (ブール)

確認が行われない場合に失敗するかどうか。

false

Boolean (ブール)

メッセージをキューにルーティングできない場合に操作に失敗するかどうか。

false

Boolean (ブール)

メッセージをキューコンシューマーに即時にルーティングできない場合に操作に失敗するかどうか。

false

String (文字列)

返されるメッセージをパブリッシュするエクスチェンジ。

Integer (整数)

この項目では、プリフェッチサイズウィンドウを定義します。ブローカーは、prefetchSize ウィンドウ (バイト) を超えない範囲でできるだけ多くのメッセージを送信します。特定の上限を設定しない場合は、​0​ を使用します。

0

Integer (整数)

メッセージ全体に関してグローバルプリフェッチウィンドウを指定します。この項目は、プリフェッチサイズ項目と組み合わせて使用します。両方のプリフェッチウィンドウで許可されている場合にのみメッセージが事前に送信されます。特定の上限を設定しない場合は、​0​ を使用します。

0

Boolean (ブール)

基盤となる AMQP Connector に設定するキープアライブ (v1.5.0 以降)。

false

Enumeration (列挙)。次のいずれかになります。

SO_TIMEOUT​ AMQP 接続ソケット設定の時間単位 (v1.5.0 以降)。

MILLISECONDS

Integer (整数)

基盤となる AMQP Connector に設定する ​SO_TIMEOUT​ (v1.5.0 以降)。

ユーザー環境のデフォルト

Integer (整数)

基盤となる AMQP Connector に設定する受信バッファサイズ (v1.5.0 以降)。

ユーザー環境のデフォルト

Integer (整数)

基盤となる AMQP Connector に設定する送信バッファサイズ (v1.5.0 以降)。

ユーザー環境のデフォルト

String (文字列)

使用する設定の名前。

x

String (文字列)

メッセージがコンシュームされるキューの名前。

x

String (文字列)

メッセージのコンテンツタイプ。

String (文字列)

メッセージのコンテンツエンコード。

Definition of a Queue (キューの定義)

queueName のキューがない場合にキューを宣言するために使用されるキュー定義。

Enumeration (列挙)。次のいずれかになります。

メッセージとセッションで設定する ConsumerAckMode。

Number (数値)

タイムアウトとなる前にメッセージを待つ最大時間。

10000

Enumeration (列挙)。次のいずれかになります。

[Maximum wait time (最大待機時間)]​ 設定で使用する時間単位。

MILLISECONDS

Enumeration (列挙)。次のいずれかになります。

トランザクションに関する操作で実行できる結合アクションの種別。

JOIN_IF_POSSIBLE

接続エラーが発生した場合の再試行戦略。

String (文字列)

使用する設定の名前。

x

String (文字列)

メッセージのパブリッシュ先のエクスチェンジの名前。

x

Definition of an Exchange (エクスチェンジの定義)

exchangeName のエクスチェンジがない場合にエクスチェンジを宣言するために使用されるエクスチェンジ定義。

LIST

ルーティングキーのリスト。

Enumeration (列挙)。次のいずれかになります。

AMQP ブローカーにパブリッシュするときに使用する配信モード。

PERSISTENT

String (文字列)

メッセージの AMQPCorrelationID ヘッダー。

String (文字列)

本文のコンテンツタイプ。

String (文字列)

メッセージの本文の outboundEncoding。

String (文字列)

このメッセージの返信先となるキューの AMQP ​replyTo​ プロパティ情報。

Object (オブジェクト)

このメッセージについて設定するカスタムユーザープロパティ。各プロパティは他のデフォルトの AMQP ユーザープロパティとマージされます。すべての AMQP ユーザープロパティは単一のオブジェクトで一度に設定されます。このオブジェクトは、​#[output application/json --- { userName: vars.user, appName: 'myApp'}]​ のように DataWeave オブジェクトとして書き込めます。続いて、ユーザープロパティオブジェクトのそれぞれのキー/値が個別の AMQP ユーザープロパティとして設定されます。

接続エラーが発生した場合の再試行戦略。

String (文字列)

使用する設定の名前。

x

String (文字列)

メッセージのパブリッシュ先のエクスチェンジの名前。

x

String (文字列)

メッセージの AMQPCorrelationID ヘッダー。

String (文字列)

本文のコンテンツタイプ。

/

String (文字列)

メッセージの本文の outboundEncoding。

Object (オブジェクト)

このメッセージについて設定する必要があるカスタムユーザープロパティ。各プロパティは他のデフォルトの AMQP ユーザープロパティとマージされます。すべての AMQP ユーザープロパティは単一のオブジェクトで一度に設定されます。このオブジェクトは、​#[output application/json --- { userName: vars.user, appName: 'myApp'}]​ のように DataWeave オブジェクトとして書き込めます。続いて、ユーザープロパティオブジェクトのそれぞれのキー/値が個別の AMQP ユーザープロパティとして設定されます。

Number (数値)

タイムアウトとなる前にメッセージを待つ最大時間。

10000

Enumeration (列挙)。次のいずれかになります。

maximumWaitTime 設定で使用する時間単位。

MILLISECONDS

接続エラーが発生した場合の再試行戦略。

String (文字列)

肯定応答するメッセージの AckId。

x

String (文字列)

肯定応答するメッセージの AckId。

x

Boolean (ブール)

拒否されたメッセージをキューに再登録する必要があるかどうかを示します。

false

String (文字列)

使用する設定の名前。

x

String (文字列)

コンシュームするキューの名前。

x

Number (数値)

AMQP メッセージを受信するために使用する同時コンシューマー数。

4

String (文字列)

コンテキストを確立するためにクライアントによって生成されたコンシューマータグ。

4

Enumeration (列挙)。次のいずれかになります。

チャネル回復またはロールバックの実行時に使用する戦略。

REQUEUE

String (文字列)

メッセージ本文のコンテンツタイプ。

String (文字列)

メッセージの本文の inboundEncoding。