在apache-camel中处理连接故障

Question

null

Answer 1

要在出现故障时自动恢复RabbitMQ资源（连接/通道/消费者/队列/出口/绑定），请查看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交换您自己的资源创建。