Anypoint MQ Connector リファレンス - Mule 4

Name (名前)

String (文字列)

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

x

Connection (接続)

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

x

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

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Runtime でパージに相当するとみなされます。必要に応じて、期限切れのインスタンスがパージされてリソースが解放されます。

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Ack Token (Ack トークン)

MANUAL モードでのみ、手動 ACK および NACK 操作を実行するために使用される肯定応答トークン。

x

Reconnection Strategy (再接続戦略)

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

Anypoint MQ Connector ではこのパラメーターはサポートされていません。 詳細は、​「Anypoint MQ Connector で再試行戦略を使用できますか?」​を参照してください。

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Queue (キュー)

メッセージのフェッチ元であるキューまたはエクスチェンジの名前。

x

Acknowledgment Mode (肯定応答モード)

取得したメッセージに使用する肯定応答モード。

IMMEDIATE

肯定応答タイムアウト

肯定応答または否定応答を待機しているコンシューマーによってメッセージが保持される期間。その期間が経過した後、任意のコンシューマーがメッセージを再び利用できるようになります。

0

Acknowledgment Timeout Unit (肯定応答タイムアウト単位)

acknowledgmentTimeout 設定に使用する時間単位。

MILLISECONDS (ミリ秒)

Polling Time (ポーリング時間)

10000

Polling Time Unit (ポーリング時間単位)

pollingTime 設定に使用する時間単位。

MILLISECONDS (ミリ秒)

Output Mime Type (出力 MIME タイプ)

操作の出力の MIME タイプ。

Output Encoding (出力エンコード)

操作の出力のエンコード。

Streaming Strategy (ストリーミング戦略)

反復可能なストリームを使用します。

Target Variable (対象変数)

操作の出力を保存する変数の名前。

Target Value (対象値)

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

#[payload]

Reconnection Strategy (再接続戦略)

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

Anypoint MQ Connector ではこのパラメーターはサポートされていません。 詳細は、​「Anypoint MQ Connector で再試行戦略を使用できますか?」​を参照してください。

型

Binary (バイナリ)

Attributes Type (属性型)

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Ack Token (Ack トークン)

MANUAL モードでのみ、手動 ACK および NACK 操作を実行するために使用される肯定応答トークン。

x

Reconnection Strategy (再接続戦略)

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

Anypoint MQ Connector ではこのパラメーターはサポートされていません。 詳細は、​「Anypoint MQ Connector で再試行戦略を使用できますか?」​を参照してください。

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Destination (宛先)

メッセージのフェッチ元であるキューまたはエクスチェンジの名前。

x

Output Mime Type (出力 MIME タイプ)

操作の出力の MIME タイプ。

Output Encoding (出力エンコード)

操作の出力のエンコード。

Streaming Strategy (ストリーミング戦略)

反復可能なストリームを使用します。

Body (本文)

送信メッセージの本文。JSON メッセージの一部の文字列として送信されます。パブリッシュされるコンテンツは、文字列形式の逐次化と並列化を実行できる必要があります。文字列が適切に逐次化されていないオブジェクトを送信すると、受信側でメッセージが読めなくなります。

#[payload]

User Properties (ユーザープロパティ)

メッセージに設定されたカスタムユーザープロパティ。

Message Id (メッセージ ID)

送信メッセージの有効なカスタムユーザー ID。指定されていない場合、ブローカーによって作成されます。

Message Group Id (メッセージグループ ID)

パブリッシュされたメッセージが属するメッセージグループの ID。FIFO キューでのみ指定します。

メッセージグループ ID には最大 128 文字の英数字 (a-z, A-Z、0-9) および句読点 (! " # $ % & ' ( ) * + , - . / : ; < = > ? @ [ ] \ ^ _ ` { } | ~) を含めることができます。

Delivery Delay (配信遅延)

コンシュームする前にメッセージの配信を延期する時間 (0 ～ 15 分)。

MILLISECONDS (ミリ秒)

Delivery Delay Unit (配信遅延単位)

MILLISECONDS (ミリ秒)

Send Content-Type (コンテンツタイプの送信)

本文種別が Anypoint MQ メッセージプロパティとして送信される場合は true に設定します。

true

Target Variable (対象変数)

操作の出力を保存する変数の名前。

Target Value (対象値)

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

#[payload]

Reconnection Strategy (再接続戦略)

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

Anypoint MQ Connector ではこのパラメーターはサポートされていません。 詳細は、​「Anypoint MQ Connector で再試行戦略を使用できますか?」​を参照してください。

型

Binary (バイナリ)

Attributes Type (属性型)

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Queue (キュー)

メッセージの取得元のキューの名前。

x

Subscriber Type (サブスクライバー種別)

サービスからメッセージにサブスクライブするときに使用する戦略。

Acknowledgment Mode (肯定応答モード)

取得したメッセージに使用する肯定応答モード。

AUTO

肯定応答タイムアウト

サブスクライバーが使用可能になる前に、肯定応答または否定応答を待機しているブローカーによってメッセージが保持される期間。上書きされていない場合のすべての Subscriber ソースのデフォルトの ​acknowledgmentTimeout​ 値を指定します。 このパラメーターの最大値は 12 時間です。

acknowledgementTimeout​ が設定されていない場合 (デフォルト)、コネクタでは少なくとも 2 分の TTL 値が使用されます。

Acknowledgment Timeout Unit (肯定応答タイムアウト単位)

acknowledgmentTimeout 設定に使用する時間単位。

MILLISECONDS (ミリ秒)

サーキットブレーカー

Output Mime Type (出力 MIME タイプ)

操作の出力の MIME タイプ。

Output Encoding (出力エンコード)

操作の出力のエンコード。

Primary Node Only (プライマリノードのみ)

クラスターでの実行時、このソースをプライマリノード上でのみ実行する必要があるかどうか。

Streaming Strategy (ストリーミング戦略)

反復可能なストリームを使用します。

Redelivery Policy (再配信ポリシー)

メッセージ再配信ポリシー。

Reconnection Strategy (再接続戦略)

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

Anypoint MQ Connector ではこのパラメーターはサポートされていません。 詳細は、​「Anypoint MQ Connector で再試行戦略を使用できますか?」​を参照してください。

型

Binary (バイナリ)

Attributes Type (属性型)