如何重新初始化DefaultConsumer的频道关机

  • Z时代
  • 2024-01-10
  • 分类：问答

我使用的是RabbitMQ的DefaultConsumer如何重新初始化DefaultConsumer的频道关机

public void init() { 
    DefaultConsumer dc = new DefaultConsumer(channel); 
    dc.addShutdownListener(this); 
} 
handleShutdownSignal() { 
    //TODO: Recreate channel associated with this consumer 
}

一旦有与渠道的错误，并且shutdownsignal是送的，我怎么能重新初始化通道，因为消费者已经依赖于之前使用的频道？

回答：

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

以上是 如何重新初始化DefaultConsumer的频道关机 的全部内容， 来源链接： utcz.com/qa/266346.html

回到顶部