2017-04-06 1 views
1

json 메시지를 푸시하는 동안 NIFI의 PublishJMS 프로세서에 문제가 있습니다.PublishJMS 프로세서가 IBM Websphere MQ에 json 메시지를 게시하는 동안 실패했습니다

참고 : 그냥 속성이 수정 될 수 있는지 확인하기 위해 다양한 프로세서를 시도 추가하려면, 그러나 아무도 내가이 같은 흐름에 함께 & PublishJMS을 ConsumeJMS를 사용하고 있습니다 만 있기 때문에이 문제가 알아낼 수 있어요, 도움이되지 않습니다.

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의'를 사용 설정해야하지 'java.lang.String의' "는 이전 post에 게시 된 솔루션에 따라 해결되며 아래 흐름에서 json 메시지를 MQ 대기열에 게시 할 수 있습니다.

QueryDatabaseTable> ConvertAvroToJSON> PublishJMS

하지만이 아래에 언급 된 흐름을 PublishJMS이다 사용하고 때 PublishJMS 프로세서에서 이전 포스트에서보고 저도 같은 오류를 얻고있다.

ConsumeJMS>에서는 replaceText> PublishJMS

내가 실종 무엇?

메시지를 성공적으로 게시하려면 PublishJMS를 사용하기 전에 다른 프로세서를 연결해야합니까?

이 문제에 대한 도움을 주시면 감사하겠습니다.

다음은 프로 세서의 속성입니다.

ConsumeJMS 속성 : enter image description here

DataProvenance PublishJMS 프로세서 enter image description here

에서는 replaceText 특성 enter image description here

PublishJMS 특성 enter image description here enter image description here enter image description here

,

답변

1

감사합니다. @andrew님께 정확합니다. 그러나 IBM Websphere MQ jar v7.5 이하의 문제를 해결하고이를 극복하기 위해 수행 한 정확한 수정을 원합니다.

UpdateAttribute 프로세서를 사용하여 Apache Nifi의 Flowfile에서 아래에 언급 된 속성을 삭제했는지 확인해야했습니다.

JMS_IBM_MsgType, 또한

그리고 JMS_IBM_Encoding & JMS_IBM_PutApplType은 같은 이름의 추가 속성을 추가하여 Flowfile의 정수로 동일한 속성을 대체합니다.

부착 된 UpdateAttribute 프로세서의 스크린 샷이 첨부되었습니다. enter image description here

enter image description hereenter image description here

실제 문제가 아파치 NIFI 고정 될 때까지이 작업 주위로는 도움이되기를 바랍니다.

1

전송하기 전에 JMS로 시작하는 모든 속성을 삭제 해보십시오. 이를 위해 정규식 마스크로 UpdateAttribute를 사용하십시오.

관련 문제