RabbitMQ basic.get 和确认
我正在调用: GetResponse response = channel.basicGet("some.queue", false); // no auto-ack .... channel.basicAck(deliveryTag, ...); 但是,当…
使用来自 Apache Qpid java 客户端的 RabbitMQ 服务器消息?哪个版本?
我必须使用 Apache qpid java 客户端使用rabbitmq-server(因为我必须使用 Apache Camel)。但我对它们的版本感到困惑,特别是因为它们都支持 amqp 协…
如何在多租户系统中的 RabbitMQ 中使队列私有/安全?
我已阅读 RabbitMQ 提供的 入门 指南,甚至还向 stormed-amqp,所以我对AMQP。 然而,该指南并不全面,并且避免了身份验证和授权等内容。 我们正在设…
如何在 RabbitMQ/pika 中实现优先级队列
我希望用 RabbitMQ 实现优先级队列。邮件列表建议使用多个队列,每个队列代表不同的优先级。 我的问题是,如何使用 pika (或者可能是其他一些 python…
如何在同一个 EventMachine 反应器中运行 Net::SSH 和 AMQP?
一些背景信息:Gerrit 通过 SSH 公开事件流。这是一个可爱的技巧,但我需要将这些事件转换为 AMQP 消息。我尝试使用 ruby-amqp 和 Net::SSH 但是,好…
Node.js + socket.io +当“re”连接时,node-amqp 和队列 binginds通过 socket.io 连接
我有一个非常接近此示例的场景: 一个主屏幕: 此屏幕(客户端)将通过 server:9090/scope 连接到 socket.io 服务器(io.connect("http://server :909…
哪个消息队列可以处理订阅者断开连接后仍然存在的私有队列?
我对需要消息队列的系统有一些要求: 订阅者应获得单独的队列。 当订阅者断开连接时,不应删除各个队列 如果失去连接,订阅者应能够重新连接到自己的…
如何使用 amq.topic 在 Apache Qpid 中发布/订阅消息
我有一个 C++ 发布者发送这样的消息: Connection connection; connection.open("127.0.0.1", 5672); Session session = connection.createSession();…
使用 Python、Pika 和 AMQP 设计异步 RPC 应用程序的最佳模式是什么?
我的应用程序的生产者模块由想要提交要在小型集群上完成的工作的用户运行。它通过 RabbitMQ 消息代理以 JSON 形式发送订阅。 我尝试了几种策略,到目…
使用 node-amqp 模块在 Node.js 中手动确认
我正在使用 postwait 模块 node-amqp 。 我可以向队列发布/订阅一些消息,但我想手动确认这些消息。 例如,我希望读取消息但不确认消息,然后对此消息…
Rabbitmq 与 Apache QPID
我试图找出这两个消息队列中的哪一个。我最初对 RabbitMQ 感兴趣,但由于它(rabbitmq)不提供稳定的 C/C++ 客户端并且似乎没有持久存储(?)…
使用 Node.js 的 AMQP,如何发布/订阅?
我正在创建一个操作 Node-AMQP 模块的类: https://github.com/postwait/node -amqp 但我无法使用它发布/订阅: var Queue = require('./Queue.js'); …
puka 可以与 gevent 或 eventlet 配合使用吗?
我正在阅读有关较新的 Python AMQP 库 Puka(不要与 Pika 混淆)的信息,并且想知道它处理事件循环的方式是否与 gevent 或 eventlet 兼容。根据我有限…
将大量消息发布到AMQP队列
使用 Ruby amqp 库的 v0.7.1 和 Ruby 1.8.7,我尝试将大量(数百万)短(~40 字节)消息发布到 RabbitMQ 服务器。我的程序的主循环(好吧,不是真正的…