我有一个向 RabbitMQ 集群发送消息的应用程序。如果该集群由于某种原因出现故障，这些事件将使用 Bunny ruby gem 进行缓冲。当该集群启动时，所有缓冲的消息会立即发送，从而导致发布到 RabbitMQ 端的 CPU 负载大幅增加。
是否有一些简单的方法可以限制集群恢复时每秒发送的消息的速率，因此它们仅以每秒 100 条左右的速度发送？
我正在修改的代码是 logstash AMQP 输出插件：
https://github.com/logstash/logstash/blob/master/lib/logstash/outputs/amqp.rb