PublishJMS 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-jms-processors-nar
説明¶
FlowFile のコンテンツから JMS メッセージを作成し、 JMS 宛先 (キューまたはトピック) に JMS BytesMessage または TextMessage として送信します。FlowFile 属性は JMS ヘッダーやプロパティとして JMS メッセージに追加されます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
接続クライアント ID |
もしセットされていれば、接続に設定されるクライアントID。耐久性のある非共有コンシューマーでは必須ですが、それ以外のコンシューマーではオプションです。一般的には共有コンシューマーとはセットされていることは望ましくありません。詳細は JMS のスペックをご覧ください。 |
接続工場サービス |
接続ファクトリの取得に使用するController Service。また、 'JNDI *' または 'JMS *' プロパティを使用して接続ファクトリを構成することもできます。 |
デスティネーション名 |
JMS 送信先の名前。通常は管理者が提供します（例：'topic://myTopic'または'myTopic'）。 |
デスティネーションタイプ |
JMS 送信先のタイプ。'QUEUE' または 'TOPIC' のいずれかです。通常は管理者が提供します。デフォルトは 'QUEUE' です。 |
最大バッチサイズ |
プロセッサーの各呼び出しで発行または消費するメッセージの最大数。 |
パスワード |
認証および承認に使用されるパスワード。 |
SSL コンテキストサービス |
TLS/SSL 接続のクライアント証明書情報を提供するために使用される SSL コンテキストサービス。 |
ユーザー名 |
認証と承認に使用されるユーザー名。 |
allow-illegal-chars-in-jms-header-names |
ヘッダー名の不正な文字を JMS ブローカーに送るかどうかを指定します。通常はハイフンとフルストップ。 |
attributes-to-send-as-jms-headers-regex |
JMS ヘッダーとして送信されるべき FlowFile 属性の名前を決定する正規表現を指定します。 |
broker |
URI は JMS メッセージブローカーのネットワークの場所を指しています。ActiveMQ の例: 'tcp://myhost:61616'.IBM MQ の例: 'myhost(1414)' と 'myhost01(1414),myhost02(1414)'. |
cf |
JMS ConnectionFactory 実装クラスの完全修飾名 (例: org.apache.activemq.ActiveMQConnectionFactory)。 |
cflib |
クラスパスに追加するリソース (JARs や構成ファイルなど) があるディレクトリへのパス (カンマ区切りの値リストとして定義します)。このようなリソースは通常、 ConnectionFactory 実装のターゲット JMS クライアントライブラリを表します。 |
character-set |
TextMessages を構築または解釈するために使用する文字セットの名前。 |
接続.ファクトリー.名 |
接続ファクトリを検索する JNDI オブジェクトの名前。 |
Java.naming.factory.initial |
JNDI 初期コンテキスト・ファクトリー・クラス（java.naming.factory.initial）の完全修飾クラス名。 |
java.naming.provider.url |
java.naming.provider.urlの値として使用する JNDI Providerの URL。許可される URL スキームについては、追加の詳細ドキュメントを参照してください。 |
java.naming.security.credentials |
JNDI (Java.naming.security.credentials)で認証する際に使用する認証情報。 |
java.naming.security.principal |
JNDI (java.naming.security.principal)で認証する際に使用するPrincipal。 |
message-body-type |
構築する JMS メッセージ本文のタイプ。 |
naming.factory.libraries |
JNDI / JMS クライアント・ライブラリをロードするために ClassPath に追加する jar ファイルおよび/またはディレクトリを指定します。これはコンマで区切られたファイル、ディレクトリ、 URLs のリストでなければなりません。ディレクトリが指定された場合、そのディレクトリ内のファイルはすべて含まれますが、サブディレクトリは含まれません（つまり、再帰的ではありません）。 |
record-reader |
入力された FlowFile を記録にパースするために使用するRecord Reader。 |
record-writer |
JMS メッセージとして発行する前に記録をシリアライズするために使用する Record Writer。 |
制限事項¶
必要な許可 |
説明 |
|---|---|
リファレンス リモート リソース |
クライアントライブラリの場所は、 HTTP 以下のリソースをリファレンスできます。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
JMS 宛先に送信できないすべての FlowFiles は、このリレーションシップにルーティングされます。 |
success |
JMS 宛に送信されるすべての FlowFiles は、このリレーションシップにルーティングされます。 |