rabbitmq - 如何在关闭时重新初始化 DefaultConsumer 的频道

Question

我正在使用 RabbitMQ DefaultConsumer

public void init () {

  DefaultConsumer dc = new DefaultConsumer(channel);

  dc.addShutdownListener(this);

}

handleShutdownSignal() {
   //TODO: Recreate channel associated with this consumer
}

一旦通道出现错误并发送关闭信号，我该如何重新初始化通道，因为消费者已经依赖于它使用的前一个通道？

Answer 1

您将需要重新建立连接，创建一个通道，然后创建一个新的消费者。如果连接仍然正常，您可以使用它来获取新频道。