Rails 应用程序内的 AMQP 订阅者
是否可以使用我的 Rails 应用程序启动 AMQP 订阅者?可能通过初始化程序或其他东西。 我想让它同时运行,也可以与 Rails 模型交互。下面是我的意思的…
在两个 RabbitMQ 队列中发布消息,而不是一个(使用 py-amqp)
我使用 py-amqp 和 Flopsy 模块。我编写了一个将消息发送到 RabbitMQ 服务器的发布者,并且我希望能够将其发送到指定的队列。在 Flopsy 模块上这是不…
ActiveMQ 与Camel - 如何在路由路径中创建依赖关系
我有一个要实现的消息路由,它的路由根据消息内容而变化。路线的某些部分依赖于其他部分。 例如,如果我有 Data_A,其中有 Task_A 和 Task_B 要对其执…
使用 AMQP、Rabbit 和 Ruby 刷新队列
我正在用 Ruby 开发一个系统,该系统将利用 RabbitMQ 在执行某些工作时将消息发送到队列。我正在使用: Ruby 1.9.1 Stable RabbitMQ 1.7.2 AMQP gem v…
windows-ce 中的哪些消息传递技术可以保证消息传递?
我们正在构建一个基于 windows-ce (6.0R3) 的设备,该设备需要有保证且可审计的消息向上和向下传输(包括存储和转发)。 我一直在寻找超越以下的选择…
Erlang AMQP 客户端库
是否有一个 Erlang AMQP 客户端库不与 RabbitMQ 绑定在一起? 我知道 rabbitmq-erlang-client 但我想要一些更加解耦的东西。当涉及到将这些东西打包到…
使用RabbitMQ(Java客户端),有没有办法确定消费期间网络连接是否关闭?
我在 RHEL 5.3 上使用 Java 客户端使用 RabbitMQ。我有 2 个节点(机器)。 Node1 正在使用 Java 帮助器类 QueueingConsumer 消费 Node2 上队列中的消…
txAMQP可以在RabbitMQ中解绑吗?
我想删除 RabbitMQ 中的绑定而不删除绑定队列。我正在使用 txAMQP 和 0.8 AMQP 规范;它似乎是 RabbitMQ 支持的唯一版本,但它没有 unbind 方法。 奇…
多个消费者&连接到消息队列的生产者,这在 AMQP 中可能吗?
我想创建一个能够 OCR 文本的进程群。 我考虑过使用由多个 OCR 进程读取的单个消息队列。 我想确保: 队列中的每条消息最终都会得到处理 工作或多或少…
如何在AMQP的python客户端中使用listen on basic.return
我想确保我的消息已传递到队列中。 为此,我将强制参数添加到 basic_publish 中。 如果我的消息未成功发送,我还应该做什么才能收到 basic.return 消…
Zeromq/AMQP 可插入吗?
[1] 我正在阅读 AMQP 标准,似乎交换、队列和绑定组件之间有明确的分离。然而,查看 Zeromq 文档,Zeromq 似乎不允许您插入自己的交换/队列/绑定实现…