在 django 中中止 Celery 中正在运行的任务
我希望能够中止从 Celery 队列运行的任务（使用rabbitMQ）。我使用 AsyncBoot 来调用该任务， task_id = AsyncBoot.apply_async(args=[name], name=na…
如何实现用于 WAS 激活的自定义消息队列侦听器？
我正在编写 .Net 4.0 Web 解决方案的组件（在 IIS7、WS2008 上），并且需要提供可以使用消息队列中的消息的服务。我找到了使用 MSMQ 配置 WAS 服务激…
基于 RabbitMQ 消息消费 ID（c# API）
我想发布/生成带有某些消息ID的消息，就像每条消息都有一个特定的ID一样。 在消费者端，我想通过提供ID来检索消息。 假设我们有多个消费者，那么每个…
RabbitMQ C# API 基于事件的消息消费
while (true) { BasicDeliverEventArgs e = (BasicDeliverEventArgs)Consumer.Queue.Dequeue(); IBasicProperties properties = e.BasicProperties; b…
如何有选择地从 AMQP (RabbitMQ) 队列中删除消息？
我想有选择地从 AMQP 队列中删除消息，甚至不读取它们。 场景如下： 发送方希望基于类型X的新信息到达的事实使类型X的消息过期。因为订阅者很可能还没…
像 yammer 这样的服务将如何使用 xmpp？ xmpp 是否与队列交叉？
像 yammer 这样的服务将如何使用 xmpp？ xmpp 是否与队列交叉？即可以使用rabbitmp代替xmpp还是它们是完全不同的东西？…
RabbitMQ 上 celery 任务优先级的解决方法？
我在 RabbitMQ 之上运行 Django 和 Celery 作为队列来处理一些数据处理任务。当用户首次注册时，我会启动 celery 任务，并定期更新他们的数据。但是，…
RabbitMQ/AMQP 未处理的通道错误 - NOT_FOUND
我正在尝试从 Ruby 脚本（使用 Bunny）向 RabbitMQ 发布消息，并从Node.js 服务器（使用 node-amqp）。 第一条消息成功到达，但随后在 Node.js 中记录…
RabbitMQ消息消费者停止消费消息
我们的团队正急于在 ActiveMQ 或 RabbitMQ 之间进行选择。我们制作了 2 个小生产者/消费者峰值，发送一条包含 16 个字符串数组、一个时间戳和 2 个整…
使用 RabbitMQ 和 Python 进行基于内容的路由
是否可以使用 RabbitMQ 和 Python 进行基于内容的路由？ AMQP 标准和 RabbitMQ 声称支持基于内容的路由，但是 Python 是否有任何库支持指定基于内容的…
RabbitMQ 与 Mule 相比如何
RabbitMQ 与 Mule 相比如何，我将使用面向消息的架构构建一个应用程序，AMQP（RabbitMQ）提供了我想要的一切，但我对如此多的相关技术选择和类似的概…
RabbitMQ 中的内容类型标头有什么特殊含义吗？
RabbitMQ 中的内容类型标头是否有任何特殊含义，或者它只是我的生产者和消费者发送信号类型的标准化方式？换句话说：具有某些内容类型的消息是否会得…
amqp 或 xmpp 用于实时在线游戏
Closed. This question is seeking recommendations for software libraries, tutorials, tools, books, or other off-site resources. It does not …
