Six Stars

how to process multiple queue messages of tmominput

Hi,

I have a job where the messages from tmominput component are to be passed trest component. Data Flow as follows:

 

tMomInput-->tmap-->tFileOutputExcel_1

                          |---->rFileOutputExcel_2

 

tREST-->tExtractJSONField--tJavaRow

 

Now, I need to connect tmomInput subjob to tREST subjob so that messages in the queue should process in parallel at tREST as one flow instead of considering as 2 subjobs (means --- same message which goes to tmap should flow to tREST as well at the same time) . What to I do? Please suggest something which requires less/no coding.

 

  • Big Data
2 REPLIES
Nine Stars TRF
Nine Stars

Re: how to process multiple queue messages of tmominput

Hi,
You may add a tReplicate after tMomInput to replicate the flow.
Then, connect one branch to tMap and an other one to tRest.

TRF
Six Stars

Re: how to process multiple queue messages of tmominput

Hi,
tREST is an input component. So I cannot connect tReplicate (main) to tREST. I need the flow to pass to tREST per message. Also, When I do -
tMomInput/tFileOutputExcel--onComponentOk -->tREST
After one message has processed , the jobs ends with the error message "A WebSphere MQ error occurred : Completion code 2 Reason code 2018"

How do I make it run in a loop as in the messages should process to tREST ( & tFileOutputExcel) as long as queue is not empty?