реконнект
сообщения обрабатываю через метод IncomingMessage.process
но, когда соединение рвется, то обрабатываемое сообщение теряется, как я понимаю из-за закрытия канала в коннекте
робуст при реконнекте, почему то создает новый канал, а не поднимает старый
В доке информации очень скудно, в гугл правильный запрос подобрать немогу((
Думал поискать в коде, но там не нахожу каких-то методов для гарантированной отпраки
Подскажите, пожалуйста, как мне изменить обработку таким образом, чтобы сообщение точно отправилось, после восстановления соединения?
Какая версия aio-pika?
7.2.0 (последняя)
Смотри, сама суть в следующем, ты не знаешь в какой момент у тебя рвется соединение, и я тем более, отправка сообщения в протоколе это отправка минимум трех фреймов (в зависимости от размера cообщения). Если у тебя орвется конект на последнем фрейме ты не знаешь принял последний фрейм брокер или нет.
Обсуждают сегодня