scala - 处理 apache-camel 中的连接失败

Question

我正在编写一个 apache-camel RabbitMQ 消费者。我想以某种方式对连接问题使用react(即尝试重新连接)。是否可以将 apache-camel 配置为自动重新连接？

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

启动队列(和一些生产者)

启动我的消费者(它按预期收到消息)

停止队列(消息停止到达，正如预期的那样，但没有抛出异常)

启动队列(没有收到新消息)

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

Answer 1

对于发生故障时的自动 RabbitMQ 资源恢复(Connections/Channels/Consumers/Queues/Exchanages/Bindings)，请查看 Lyra 。用法示例:

Config config = new Config()
  .withRecoveryPolicy(new RecoveryPolicy()
    .withMaxAttempts(20)
    .withInterval(Duration.seconds(1))
    .withMaxDuration(Duration.minutes(5)));
ConnectionOptions options = new ConnectionOptions().withHost("localhost");
Connection connection = Connections.create(options, config);

API 的其余部分只是 amqp-client API，除了您的资源在发生故障时自动恢复。

我不确定camel-rabbitmq 的具体情况，但希望有一种方法可以通过Lyra 交换您自己的资源创建。