带RabbitMQ的Camel 2.12路由

Question

我一直试图使用2.12.1-snapshot中的RabbitMQComponent版本让camel进行路由。这样做，我可以很容易地消费，但在路由到另一个队列时会遇到ad问题。

CamelContext context = new DefaultCamelContext();

context.addComponent("rabbit-mq", factoryComponent());

from("rabbit-mq://localhost/test.exchange&queue=test.queue&username=guest&password=guest&autoDelete=false&durable=true")
.log("${in.body}")
.to("rabbit-mq://localhost/out.queue&routingKey=out.queue&durable=true&autoAck=false&autoDelete=false&username=guest&password=guest")
.end();

在这篇文章中，我已经验证了指定的交换机是否配置了适当的路由密钥。我注意到，我能够大量消费，但不能生产到out.queue。

以下是对处理消息的RabbitMQProducer的唯一引用。

09:10:28,119 DEBUG RabbitMQProducer[main]: - Starting producer: Producer[rabbit-mq://localhost/out.queue?autoAck=false&autoDelete=false&durable=true&password=xxxxxx&routingKey=out.queue&username=guest]
09:10:48,238 DEBUG RabbitMQProducer[Camel (camel-1) thread #11 - ShutdownTask]: - Stopping producer: Producer[rabbit-mq://localhost/out.queue?autoAck=false&autoDelete=false&durable=true&password=xxxxxx&routingKey=out.queue&username=guest]

我花了很多时间研究了RabbitMQ组件的Camel单元测试，但没有看到任何非常有价值的用途。有没有人能把它弄好？

Answer 1

我是用spring DSL做的。这是我用的网址。在java dsl中端口号不是必需的吗？

rabbitMQ：//localhost:5672/subscribeExchange？queue=subscribequeue&durable=true&username=guest&password=guest&routingkey=subscribe