topic Re: how to process multiple queue messages of tmominput in Talend Studio

how to process multiple queue messages of tmominput

Anonymous — Sat, 16 Nov 2024 09:41:58 GMT

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.

Re: how to process multiple queue messages of tmominput

TRF — Fri, 02 Jun 2017 07:29:18 GMT

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

Re: how to process multiple queue messages of tmominput

Anonymous — Fri, 02 Jun 2017 10:56:10 GMT

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?