Согласно документации Pika «брокер RabbitMQ использует обратное давление TCP, чтобы замедлить вашего клиента, если он доставляет сообщения слишком быстро». Я зарегистрировал обратный вызов обратного давления, но он еще не вызван. В моей очереди более 40 миллионов сообщений, и она растет. Установив множитель обратного давления на -1, я могу получить обратный вызов, который будет вызываться при каждой публикации сообщения, но это полезно только для отладки.