我有一个使用Rabbus (使用Wascally的RabbitMQ抽象)的发送/接收实现。
由于资源限制,我只能在固定时间段内使用给定数量的作业。因此,我需要暂停/停止消费者/接收器一段时间,然后恢复。有没有一种方法可以从Rabbus中使用basic.cancel
,或者有其他方法?
发布于 2016-02-02 22:58:39
您的使用者有一个.stop()方法,但没有文档记录。我将不得不运行一个测试,看看您是否可以停止并重新启动消费者而不会出现问题……我想是的,但我从来没有真正测试过,因为我不需要这样做。我会让你知道我发现了什么
https://stackoverflow.com/questions/35159158
复制