如何解决Talend ESB 和 RabbitMQ：将侦听器/消费者连接到队列
我目前正在尝试使用 Talend open studio for ESB 为 RabbitMQ 队列构建使用者。在阅读了我能找到的关于这个主题的每一篇文章后，我有 2 个不同的版本，但没有一个真正有效。
版本 1：
我的路线：
cMessagingEndpoint1 URI：
"rabbitmq://host:port/exchange?username=xxxxx&password=xxxx&queue=xxxx"
我还尝试向此 URI 添加持久 = true 和 no_declare = true，但随后收到未知参数错误。所以我再次删除了那两个。
cMessagingEndpoint Camel component
控制台输出：这似乎是旧语法，驱动程序错误导致连接关闭。
[WARN ] 09:29:07 org.apache.camel.component.rabbitmq.RabbitMQComponent- The old syntax rabbitmq://hostname:port/exchangeName is deprecated. You should configure the hostname on the component or ConnectionFactory
[WARN ] 09:29:08 com.rabbitmq.client.impl.ForgivingExceptionHandler- An unexpected connection driver error occured (Exception message: Connection reset)
[WARN ] 09:29:08 org.apache.camel.component.rabbitmq.RabbitConsumer- Unable to open channel for RabbitMQConsumer. Continuing and will try again
我认为驱动程序错误可能是因为我没有发送“durable: true,no_declare: true”，但我不确定在哪里添加这两个选项。
版本 2：
我的连接工厂
定义的实际队列。
包括durable 和no_declare。这些必须定义，否则我永远无法连接到RabbitMQ服务器
但我再次收到未知参数错误。
org.apache.camel.FailedToCreateRouteException: Failed to create route test_receiveMQMessage_cAMQP_1: Route(test_receiveMQMessage_cAMQP_1)[[From[cMQConnectionFact... because of Failed to resolve endpoint: cMQConnectionFactory1://queue:arcplace?durable=true&no_declare=true due to: Failed to resolve endpoint: cMQConnectionFactory1://queue:arcplace?durable=true&no_declare=true due to: There are 2 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{durable=true,no_declare=true}]
有人知道如何解决这个问题并将我的侦听器连接到 RabbitMQ 队列吗？
谢谢
编辑：
为了测试并确保连接是可能的，我创建了一个 ruby 脚本来将消息发布到交换并使用发送到队列的消息。这没有任何问题。
我仍在尝试让 Talend Route/Job 工作。
编辑 2：
我检查了 RabbitMQ Broker 的设置。它是基本安装，通过 TLS 支持 AMQP 0.9.1。不支持 AMQP 1.0 或 MQTT。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。