AMQP Connector リファレンス - Mule 4

String (文字列)

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

x

Connection (接続)

この設定に指定する接続型。

x

String (文字列)

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

String (文字列)

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

/

Boolean (ブール)

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

true

Boolean (ブール)

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

true

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

メッセージのパブリッシュ時に correlationId を指定するかどうか。操作レベルで指定されるカスタム相関 ID と、現在のイベントから引用されるデフォルト相関 ID の両方に適用されます。

AUTO

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

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

AMQP ブローカーからコンシュームするときに使用する肯定応答モード。チャネルでトランザクションが開かれている場合、メッセージ肯定応答はコミットによって自動的に処理され、回復はロールバックによって自動的に処理されます。

IMMEDIATE

Boolean (ブール)

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

false

Boolean (ブール)

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

false

Number (数値)

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

4

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

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

PERSISTENT

Number (数値)

AMQP ブローカーにパブリッシュするときに使用する優先度。優先度には 0 ～ 9 の値を指定できます。デフォルトは 0 です。

0

Boolean (ブール)

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

false

Boolean (ブール)

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

false

Boolean (ブール)

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

false

String (文字列)

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

Number (数値)

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

0

Number (数値)

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

0

String (文字列)

使用する設定の名前。

x

String (文字列)

メッセージをコンシュームするキューの名前。

x

String (文字列)

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

String (文字列)

メッセージ本文のエンコード。

キュー定義

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

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

メッセージをコンシュームするときに使用する肯定応答モード。

String (文字列)

操作に関与するコンシューマーに使用するコンシューマータグ。

Number (数値)

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

10000

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

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

MILLISECONDS (ミリ秒)

Boolean (ブール)

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

現在のトランザクションの情報 (存在する場合)。

JOIN_IF_POSSIBLE

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

String (文字列)

storesoperation の出力が配置される変数の名前

String (文字列)

操作の出力に対して評価される式。この式の結果が対象変数に保存されます。

#[payload]

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

String (文字列)

使用する設定の名前。

x

String (文字列)

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

Array of String (文字列の配列)

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

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

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

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

現在のトランザクションの情報 (存在する場合)。

JOIN_IF_POSSIBLE

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

アウトバウンド相関 ID を含めるかどうかのオプション。

Boolean (ブール)

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

エクスチェンジ検証をスキップします。
デフォルトでは、[Skip Exchange Validation (エクスチェンジ検証をスキップ)] 項目を設定しない場合、​Publish​ 操作によってエクスチェンジが検証されます。検証をスキップするとパフォーマンスが向上しますが、このアプローチでは、ブローカーの設定によってはエクスチェンジが存在しない場合にメッセージが失われるリスクもあります。

Exchange Defintiion (エクスチェンジ定義)

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

Any (任意)

メッセージの本文。

#[payload]

AMQP Properties (AMQP プロパティ)

メッセージのプロパティ。

Object (オブジェクト)

この AmqpMessage に設定されるカスタムユーザープロパティ。

Boolean (ブール)

パブリッシュされたメッセージからの確認を要求します。この属性が true に設定されているときに確認が提供されない場合、例外が発生します。

false

Boolean (ブール)

メッセージをキューにルーティングできない場合の対処方法をサーバーに指示します。true に設定されている場合、サーバーはルーティングできないメッセージに対して例外 (​UNROUTABLE_MESSAGE​、以下の操作仕様を参照) をスローします。false に設定されている場合、サーバーは警告なしでメッセージを破棄します。

false

Boolean (ブール)

メッセージをキューコンシューマーに即時にルーティングできない場合の対処方法をサーバーに指示します。true に設定されている場合、サーバーは配信不能メッセージに対して例外 (​UNROUTABLE_MESSAGE​、以下の操作仕様を参照) をスローします。false に設定されている場合、サーバーはメッセージをキューに入れますが、メッセージがコンシュームされるという保証はありません。

false

String (文字列)

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

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

String (文字列)

使用する設定の名前。

x

String (文字列)

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

x

String (文字列)

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

String (文字列)

メッセージ本文のエンコード。

String (文字列)

パブリッシュするルーティングキー。

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

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

Number (数値)

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

10000

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

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

MILLISECONDS (ミリ秒)

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

現在のトランザクションの情報 (存在する場合)。

JOIN_IF_POSSIBLE

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

アウトバウンド相関 ID を含めるかどうかのオプション。

Boolean (ブール)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

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

この項目は、デフォルトでエクスチェンジ検証をスキップすることを目的としており、パラメーターが設定されていない場合は操作によって検証が行われます。エクスチェンジの検証をスキップするとパフォーマンスが向上しますが、エクスチェンジが存在しない場合、ブローカー設定によってはメッセージングの損失が発生する可能性があります。

Exchange Defintiion (エクスチェンジ定義)

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

Any (任意)

メッセージの本文。

#[payload]

AMQP Properties (AMQP プロパティ)

メッセージのプロパティ。

Object (オブジェクト)

この AmqpMessage に設定されるカスタムユーザープロパティ。

Boolean (ブール)

パブリッシュされたメッセージからの確認を要求します。この属性が true に設定されているときに確認が提供されない場合、例外が発生します。

false

Boolean (ブール)

メッセージをキューにルーティングできない場合の対処方法をサーバーに指示します。true に設定されている場合、サーバーはルーティングできないメッセージに対して例外 (​UNROUTABLE_MESSAGE​、以下の操作仕様を参照) をスローします。false に設定されている場合、サーバーは警告なしでメッセージを破棄します。

false

Boolean (ブール)

メッセージをキューコンシューマーに即時にルーティングできない場合の対処方法をサーバーに指示します。true に設定されている場合、サーバーは配信不能メッセージに対して例外 (​UNROUTABLE_MESSAGE​、以下の操作仕様を参照) をスローします。false に設定されている場合、サーバーはメッセージをキューに入れますが、メッセージがコンシュームされるという保証はありません。

false

String (文字列)

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

String (文字列)

storesoperation の出力が配置される変数の名前

String (文字列)

操作の出力に対して評価される式。この式の結果が対象変数に保存されます。

#[payload]

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

String (文字列)

肯定応答するメッセージの配信タグ。

x

String (文字列)

拒否するメッセージの配信タグ。

x

Boolean (ブール)

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

false

String (文字列)

使用する設定の名前。

x

String (文字列)

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

x

キュー定義

指定された queueName のキューがブローカーに存在しない場合に使用するキュー定義の宣言。指定された queueName のキューが存在する場合は、代替を無視してそのまま使用されます。キューが存在しない場合は、参照された定義に従って新しいキューが作成されます。

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

AMQP ブローカーからコンシュームするときに使用する肯定応答モード。

Number (数値)

AMQP メッセージを受信するためにインバウンドエンドポイントごとに生成されるチャネルの数。

String (文字列)

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

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

recoverStrategy オプションの有効な値は、NONE、​NO_REQUEUE​、および REQUEUE です。

REQUEUE

String (文字列)

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

String (文字列)

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

Boolean (ブール)

存在しないキューが代替に従って作成されるか、キューが存在しない場合はエラーが発生するか。AMQP トポグラフィを変更することを目的としていない Mule アプリケーションでは、これは無効にできます。

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

ソースがトランザクションに関して実行できる開始アクションの種別。

None (なし)

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

作成するトランザクションの種別。使用できるかどうかは、Mule バージョンによって決まります。

LOCAL

Boolean (ブール)

クラスターでの Mule インスタンスの実行時、このソースをプライマリノード上でのみ実行するかどうかを決定します。

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Number (数値)

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

Number (数値)

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

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

Any (任意)

メッセージの本文。

#[payload]

AMQP Properties (AMQP プロパティ)

メッセージのプロパティ。

Object (オブジェクト)

この AmqpMessage に設定されるカスタムユーザープロパティ。

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

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

PERSISTENT

Number (数値)

AMQP ブローカーにパブリッシュするときに使用する優先度。優先度には 0 ～ 9 の値を指定できます。デフォルトは 0 です。

0

Boolean (ブール)

この属性が true に設定されているときに確認が提供されない場合、失敗するかどうか。

false

Boolean (ブール)

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

false

Boolean (ブール)

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

false

String (文字列)

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