PublishAMQP 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-amqp-nar

説明¶

FlowFile のコンテンツから AMQP メッセージを作成し、そのメッセージを AMQP Exchange に送信します。典型的な AMQP Exchange モデルでは、 AMQP Exchange に送信されたメッセージは、「ルーティング・キー」に基づいてキュー内の最終宛先（バインディング）にルーティングされます。何らかの設定ミスのために、Exchange、ルーティングキー、キュー間のバインディングがセットアップされていない場合、メッセージは最終的な宛先を持たず、戻ってきます（つまり、データはキューに入りません）。その場合、app-logとbulletinの両方にその旨のログが表示され、 FlowFile は、「失敗」関係にルーティングされます。

タグ¶

amqp、メッセージ、パブリッシュ、プット、ラビット、送信

入力要件¶

REQUIRED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
AMQP バージョン	AMQP バージョン.現在、 AMQP v0.9.1のみをサポートしています。
ブローカー	<host>:<port> (例：localhost:5672) の形式で、既知の AMQP Broker のカンマ区切りリスト。これがセットされている場合、Host NameとPortは無視されます。同じ AMQP クラスタリングクラスタのホストのみを含めます。
クライアント証明書認証有効	ユーザー名/パスワードではなく、 SSL 証明書を使用して認証します。
取引名	メッセージが送信される AMQP Exchange の名前。通常、 AMQP 管理者が提供します(例: 'amq.direct')。これは任意のプロパティです。空のままだと、メッセージはデフォルトの AMQP exchangeに送られます。
ヘッダー・パターン	FlowFile 属性に対して評価され、一致する属性を選択し、 AMQP ヘッダーとして配置する正規表現。属性名はヘッダーキーとして使用されます。
ヘッダーソース	公開メッセージに適用されるヘッダーのソース。
ホスト名	AMQP ブローカーのネットワークアドレス (例: localhost)。Brokers がセットされている場合、このプロパティは無視されます。
パスワード	認証および承認に使用されるパスワード。
ポート	AMQP ブローカーの Port を識別子とする数値（例：5671）。Brokers がセットされている場合、このプロパティは無視されます。
ルーティングキー	AMQP がexchangeから宛先キューへメッセージをルーティングするために使用するルーティングキーの名前。通常、管理者によって提供されます (例: 'myKey')。メッセージがデフォルトのExchangeに送信されるイベントの場合、このプロパティは宛先キュー名に対応します。そうでない場合は、ルーティングキーを介してExchangeからキューへのバインディングをセットする必要があります (通常、 AMQP 管理者によって)。
SSL コンテキストサービス	TLS/SSL 接続のクライアント証明書情報を提供するために使用される SSL コンテキストサービス。
ユーザー名	認証および承認に使用されるユーザー名。
仮想ホスト	セキュリティ強化のために AMQP システムを分離する仮想ホスト名。
ヘッダー.セパレーター	ヘッダーのキー値を分割する文字。値は1文字のみです。そうしないとエラーメッセージが表示されます。

リレーションシップ¶

名前	説明
failure	AMQP 宛先にルーティングできないすべての FlowFiles は、このリレーションシップにルーティングされます。
success	AMQP 宛に送信されるすべての FlowFiles は、このリレーションシップにルーティングされます。