问题标签 [bunny]

有什么方法可以暂时暂停消费者并在以后恢复它？

这是我想做的一个例子：

当我在消费者 2 处工作时，我想暂停消费者 1。有什么有效的方法可以做到这一点吗？

我有一个有 1 名工人的队列。暗示。看起来像这样：

只要作业执行，消费者就会阻塞。据我了解，该消费者一次处理一项工作。但让我感到困惑的是，在 RabbitMQ 管理 UI 中，我有时会看到该队列有 2 或 3 个 Unacked。但这怎么可能？

我正在使用兔子来设置 rabbitmq 队列。

上面的代码创建队列并绑定路由键“test_cmd”。当我重新启动 rabbitmq 服务器时，队列仍然存在，但队列绑定被删除。

我正在使用sudo invoke-rc.d rabbitmq-server restart命令重新启动rabbitmq。

Rabbit mq 版本：RabbitMQ 3.2.4，Erlang R16B03。

这是rabbitmq的默认行为吗？如何持久化我的队列绑定？

我正在尝试在 heroku 上运行消息队列。为此，我正在使用RabbitMQ Bigwig插件。

我正在使用 bunny gem 发布消息并尝试使用运动鞋 gem 接收消息。整个设置在本地机器上运行顺利。

我采取以下步骤来设置队列

我在服务器上运行这个 rake 来设置队列：

我可以在 rabbitmq 管理插件中看到这个队列，并提到了绑定。

我正在调用 TestPublisher.publish() 来发布消息。

我有这样的运动鞋工人：

我的档案

我的文件

我的运动鞋配置

我确信该消息会被发布。我能够收到有关 rabbitmq 管理插件的消息。但是运动鞋不起作用。在sneakers.log 中没有任何帮助。

在heroku上的sneakers.log：

使用 Bunny gem 订阅：

如何在不让服务器知道的情况下取消订阅？

用例：当消费者断​​开网络时，服务器不会收到通知。所以我需要找到一种方法来处理这个问题。但是当脚本退出或线程被杀死时，它显然会清理并通知服务器。

我有一个 resque 作业在某个事件中运行，最终将消息发布到 RabbitMQ 的交换，我如何检查 bunny（Rabbit MQ ruby​​ 客户端）消息是否已成功发布？

使用确认或任何方式？

提前致谢！

我正在使用 Rabbit MQ 的 Ruby 客户端（Bunny）。

我在初始化程序中移动了洞兔子配置和初始化过程。

如何从控制器或库内部访问在 Bunny 连接上打开的通道/队列？

当我打电话时，我得到了“真实”，Bunny::Session#open?但我似乎无法弄清楚如何访问该会话中我需要的所有内容。

我正在通过 JMeter 向我的应用程序发送大量数据。

我的订阅块和发布者如下所示：

还有我的 BunnyStarter 课程：

问题是，虽然我consumer.cancel在之后调用，但method_calling在我的 Rabbit MQ 管理员中，我仍然看到我在大约 6 分钟内创建了 1000 个消费者。

那是因为我发送的数据的速率和数量吗？

我该如何改进呢？

我正在尝试在本地环境中测试 RabbitMQ 和 Bunny 的功能作为概念证明。我们目前正在使用 Beaneater/Beanstalk 并希望进行更改。我在本地环境中使用 vagrant，但似乎找不到合适的 VM。

任何人都可以直接指出一个好的教程，它给出了一步一步的指导，因为我尝试过的众多似乎都采取了不同的方法。

我使用 Ubuntu14.04、Rail 5、RabbitMQ（服务器 3.6.5）、Bunny 2.5.1

我实现了 Rabbit 来服务，并尝试对其进行测试。

我写了下一个红宝石脚本：

其中Mq::RabbitService服务包括初始化兔子、连接、创建队列等

我运行的其他终端

一开始效果很好，但我只能推送 827 条消息（我不知道为什么是 837，但它始终是相同的数字）。

之后我的发布者提出错误：

我也尝试过：添加具有管理员权限的新用户，尝试添加 IP 而不是localhost地址（如192.168.0.11）结果相同。

已编辑

我将我的服务用于 RabbitMQ 连接Mq::RabbitService gist

但

也不行

也许有人知道我做错了什么？

谢谢