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

Question

我使用的是RabbitMQ的DefaultConsumer

public void init() { 

    DefaultConsumer dc = new DefaultConsumer(channel); 

    dc.addShutdownListener(this); 

} 

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

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

Answer 1

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