jsonメッセージをIBM Websphere MQに公開中にPublishJMSプロセッサが失敗する

Question

jsonメッセージをプッシュしながらNIFIのPublishJMSプロセッサの問題に直面しています。

注： だけの属性を変更することができますが、どれも助けていないかどうかを確認しようとした種々のプロセッサを追加するには、私は同じ流れの中で一緒にConsumeJMSに& PublishJMSを使用していますという理由だけで、問題がある把握することができますよ。

JSONメッセージが公開されることはします

{"dataprepcomplete":{"modelfamilytype":"property","groupid":"1","claims":[{"requestid":"1","claimid":"10001"},{"requestid":"2","claimid":"10002"}]}} 

「JMSCC0051の問題：プロパティ 'JMS_IBM_REPORT_PASS_CORREL_ID' TYPE 'java.lang.Integerの' を使用して設定する必要があり、NOT 'はjava.lang.String型' "私の以前のpostに掲載された解決策に従って解決され、以下のフローからjsonメッセージを自分のMQキューに公開することができます。

QueryDatabaseTable> ConvertAvroToJSON> PublishJMS

しかしPublishJMSプロセッサから以前の記事で報告されているように、私はPublishJMSを使用していたとき、私は同じエラーを取得していますが、下記の流れです。

ConsumeJMS>のreplaceText> PublishJMS

私は何も足りませんか？

メッセージを正常に公開するには、PublishJMSを使用する前に他のプロセッサーを接続する必要がありますか。

これについての助力は高く評価されます。

以下は、プロセッサーのプロパティです。

ConsumeJMS特性：

DataProvenance PublishJMSプロセッサの

のreplaceText特性 ​​

PublishJMS特性

Answer 1

ありがとう@andrewあなたは正しいです。 しかし、私はIBM Websphere MQ jars v7.5以下の問題を克服するために、正確な修正を加えたいと思います。

UpdateAttributeプロセッサを使用して、Apache Nifiのフローファイルから以下の属性を削除する必要がありました。同じ名前の追加の属性を追加することによってFlowfileの整数と同じ属性を置換する

JMS_IBM_MsgType、JMS_IBM_Encoding & JMS_IBM_PutApplType

また。

添付されているUpdateAttributeプロセッサのスクリーンショットが動作しました。

実際の問題は、ApacheのNIFIで固定されるまで、それは周りの仕事であるとして、それがお役に立てば幸いです。

Answer 2

JMSで始まるすべての属性を削除してから送信してください。そのために正規表現のマスクを使ってUpdateAttributeを使用してください。