处理 apache-camel 中的连接失败

Question

我正在编写一个 apache-camel RabbitMQ 消费者。我想以某种方式对连接问题做出反应（即尝试重新连接）。是否可以配置 apache-camel 自动重新连接？

如果没有，我怎样才能发现与队列的连接被中断？我做了以下测试：

• 启动队列（和一些生产者）
• 启动我的消费者（它按预期收到消息）
• 停止队列（消息停止到达，如预期，但没有抛出异常）
• 启动队列（没有收到新消息）

我在 Scala 中使用camel（通过 akka-camel），但 Java 解决方案可能也可以

Answer 1

当前的camel-rabbitmq只是在消费者或生产者启动时创建连接和通道。所以它没有机会捕获连接异常:(。