Do not input private or sensitive data. View Qlik Privacy & Cookie Policy.
Skip to main content

Announcements
See why IDC MarketScape names Qlik a 2025 Leader! Read more
cancel
Showing results for 
Search instead for 
Did you mean: 
Anonymous
Not applicable

Talend and RabbitMQ

In our current setup (where we are now introducing Talend) we have RabbitMQ already in place as our central event broker. We now want Talend to start subscribing to queues in RabbitMQ, but this wasn't as easy as I'd initially hoped.
It seems that the ConnectionFactory in Talend is using AMQP 1.0, while RabbitMQ is using AMQP 0.9. There is an experimental plugin for RabbitMQ that introduces AMQP 1.0, but I would rather have Talend use AMQP 0.9 than having experimental plugins in production. For obvious reasons 0683p000009MACn.png
What is the best way to having Talend interacting with RabbitMQ?
Labels (2)
15 Replies
mourina
Contributor
Contributor

 
I have these 2 components now. I assume there is no need for a JSON parser as I want the whole payload to be loaded in Oracle.  Again I am a bit stuck. Nothing gets passed on to the oracle table. 


0683p000009MBIp.png 0683p000009MBRo.png
vapukov
Master II
Master II

It work, how You pass body?
0683p000009MBNi.png
mourina
Contributor
Contributor

Hey Vapukov,
Its working now . I am getting something like this in my oracle table

So now I have a tJsonextract component as I want all the tags in JSON payload to come as coumns in oracle table. Or atleast the ones which I define while creating the Oracle table. Can you advice what should be the idle configuration for this tjsonextract component. 
I am a bit confused as I saw in your previous screen shot that you used the tjsonextract component directly. However in  talend documentation for this component, there is a twritejsonfield before tjsonextract

Thanks
0683p000009MBAA.png 0683p000009MBMl.png
Anonymous
Not applicable
Author

Hello,

 

I am working on something quite similar but I don't manage to make it work ... I succeed in getting messages from rabbitmq, that means my cMessagingEndpoint component is well configured. But then i need to extract all informations contained in my message (Headers and Payload). I have built the same route and job as you but i still don't know how to configure these 3 components : cSetHeader, cProcessor, cExtractJsonFields.

 

You can find attached my current work.

 

Thanks.


Capture d’écran_2018-10-15_17-56-11.png
Capture d’écran_2018-10-15_17-56-40.png
Capture d’écran_2018-10-15_17-57-08.png
Capture d’écran_2018-10-15_17-57-22.png
Capture d’écran_2018-10-15_17-57-48.png
Anonymous
Not applicable
Author

Hello guys,

 

I'm still stuck on that purpose... noone knows how to manage that ?

Anonymous
Not applicable
Author