У меня асинхронный потребитель, в основном вдохновленный здесь . Единственный вариант - я создаю канал для каждого потребителя, когда он подписывается на очередь (в потоке).
Проблема в том, что когда соединение сбрасывается, как мне убедиться, что все каналы подключены обратно, а в очередях все еще есть потребители.