Streaming queue into database / Job connect with Route ?

[Anonymous]

Trying a PoC to get data from a RabbitMQ and write into database. I can get messages out of a Queue via Route into a file and a job insert data from file into DB. Is it possible to to connect them together? Or is there a way to implement this in either job or route alone?

Thanks!

[TRF · Accepted solution]

Maybe https://community.talend.com/t5/Design-and-Development/Talend-and-RabbitMQ/td-p/65083 could help you (thank's to @vapukov for the original answer)

[Anonymous]

Hi,

From CmessagingEndpoint1, you can trigger a onSubjob ok to the InputFile.

Is this what you meant?

or

You can use tHashOutput and tHashInput components Instead of files.

Cheers!

[Anonymous]

I was on that page when trying to get rabbitMQ to work, forgot about the thread has connection to DB as well. 

Added a cTalendJob to take care of db insert and it's now working. Thanks!