rabbitmq - シャットダウン時に 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

接続を再確立し、チャネルを作成してから、新しいコンシューマーを作成する必要があります。それでも接続に問題がない場合は、それを使用して新しいチャネルを取得できる可能性があります。