[ad_1]
I'm trying to establish a Route in Talend Open Studio, which should read some data from incoming XML file and send an exchange message to RabbitMQ, which is running on CloudAMQP.
The connection URI for RabbitMQ in CloudAMQP is amqp://user:password@swan.rmq.cloudamqp.com/vhost
How should I properly configure it in Talend Open Studio?
In the "Basic Settings" tab of the component cMQConnetionFactory, I can choose between AMQP 1.0 and Customized.
If I choose the AMQP 1.0 option, I can enter the hostname, username and password. The problem is, that I have also to specify the port, and even if I leave it empty the generated URI looks like amqp://user:password@swan.rmq.cloudamqp.com/vhost:<port>
with empty <port>
and the connection can't be established.
I assume, that it should be possible to establish the connection by using the "Customized" option. After selecting this option a field "Codes" appears. An example how to connect to ActiveMQ can be found here:
new org.apache.activemq.ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");
Could anyone deliver an example how to open a connection to RabbitMQ by using the "Customized" option?
[ad_2]
لینک منبع