ConsumeJMS 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-jms-processors-nar
説明¶
BytesMessage, TextMessage, ObjectMessage, MapMessage または StreamMessage のタイプの JMS メッセージを消費し、その内容を FlowFile に変換し、'success' 関係に移行します。JMS ヘッダーやプロパティなどの属性は、 FlowFile 属性としてコピーされます。MapMessages は JSONs に変換され、さらにバイト配列に変換されます。その他のタイプは、バイト配列としてフローファイルに転送されます。
入力要件¶
FORBIDDEN
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
確認モード |
JMS 確認モード。Auto Acknowledge を使用すると、 NiFi の再起動時にメッセージが失われる可能性がありますが、クライアントアクノレッジよりもパフォーマンスが向上 する可能性があります。 |
接続クライアント ID |
もしセットされていれば、接続に設定されるクライアントID。耐久性のある非共有コンシューマーでは必須ですが、それ以外のコンシューマーではオプションです。一般的には共有コンシューマーとはセットされていることは望ましくありません。詳細は JMS のスペックをご覧ください。 |
接続工場サービス |
接続ファクトリの取得に使用するController Service。また、 'JNDI *' または 'JMS *' プロパティを使用して接続ファクトリを構成することもできます。 |
デスティネーション名 |
JMS 送信先の名前。通常は管理者が提供します（例：'topic://myTopic'または'myTopic'）。 |
デスティネーションタイプ |
JMS 送信先のタイプ。'QUEUE' または 'TOPIC' のいずれかです。通常は管理者が提供します。デフォルトは 'QUEUE' です。 |
耐久性のあるサブスクリプション |
もし宛先がTopicであれば、それをコンシューマー耐久性にします。https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createDurableConsumer-jakarta.jms.Topic-java.lang.String- を参照してください。 |
エラーキュー名 |
JMS キューの名前。セットされていれば、未処理のメッセージがルーティングされます。通常は管理者によって提供されます (例: 'queue://myErrorQueue' または 'myErrorQueue')。'Destination Type' が 'QUEUE' にセットされている場合のみアプリケーションに適用されます。 |
最大バッチサイズ |
プロセッサーの各呼び出しで発行または消費するメッセージの最大数。 |
メッセージセレクター |
JMS プロセッサーが受け取るメッセージをフィルターするメッセージセレクター |
パスワード |
認証および承認に使用されるパスワード。 |
SSL コンテキストサービス |
TLS/SSL 接続のクライアント証明書情報を提供するために使用される SSL コンテキストサービス。 |
共有サブスクリプション |
宛先がTopicの場合は、それをコンシューマー共有にします。https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createSharedConsumer-jakarta.jms.Topic-java.lang.String- を参照してください。 |
サブスクリプション名 |
デスティネーションがTopicで、共有または耐久性がある場合に使用するサブスクリプションの名前。 |
タイムアウト |
リモートブローカからのメッセージをあきらめるまでの待機時間。 |
ユーザー名 |
認証と承認に使用されるユーザー名。 |
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。 |
naming.factory.libraries |
JNDI / JMS クライアント・ライブラリをロードするために ClassPath に追加する jar ファイルおよび/またはディレクトリを指定します。これはコンマで区切られたファイル、ディレクトリ、 URLs のリストでなければなりません。ディレクトリが指定された場合、そのディレクトリ内のファイルはすべて含まれますが、サブディレクトリは含まれません（つまり、再帰的ではありません）。 |
output-strategy |
JMS メッセージを FlowFile 記録に出力するために使用される形式。 |
record-reader |
受信した JMS メッセージを記録にパースするために使用するRecord Reader。 |
record-writer |
FlowFile に書き込む前に記録をシリアライズするために使用する Record Writer。 |
制限事項¶
必要な許可 |
説明 |
|---|---|
リファレンス リモート リソース |
クライアントライブラリの場所は、 HTTP 以下のリソースをリファレンスできます。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
parse.failure |
構成されたRecord Readerを使用してメッセージを解析できない場合、メッセージの内容はこのリレーションシップに個別の FlowFile としてルーティングされます。 |
success |
JMS デスティネーションから受信したすべての FlowFiles は、このリレーションにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
jms_deliveryMode |
メッセージヘッダーの JMSDeliveryMode。 |
jms_expiration |
メッセージヘッダーの JMSExpiration。 |
jms_priority |
メッセージヘッダーの JMSPriority。 |
jms_redelivered |
メッセージヘッダーの JMSRedelivered。 |
jms_timestamp |
メッセージヘッダーの JMSTimestamp。 |
jms_correlationId |
メッセージヘッダーの JMSCorrelationID。 |
jms_messageId |
メッセージヘッダーの JMSMessageID。 |
jms_type |
メッセージヘッダーの JMSType。 |
jms_replyTo |
メッセージヘッダーの JMSReplyTo。 |
jms_destination |
メッセージヘッダーの JMSDestination。 |
jms.messagetype |
JMS メッセージのタイプは、 TextMessage、 BytesMessage、 ObjectMessage、 MapMessage、 StreamMessage のいずれかです)。 |
その他の属性 |
各メッセージ・プロパティは属性に書き込まれます。 |