PHP 驱动程序中的 AMQP 清除
为什么我必须在此方法中指定队列名称? http://www.php.net/manual/en/amqpqueue.purge.php 我使用构造函数来定义队列名称,如下所示: $this->queue …
我如何知道我的消息已使用 spring amqp 成功发送?
我正在使用 RabbitTemplate 类通过 spring amqp 写入 RabbitMQ 队列。我使用 ConvertAndSend 方法将消息发送到队列。这在正常情况下工作得很好,但如…
RabbitMQ 代理上的非活动连接到期
我的 RabbitMQ 代理遇到了连接限制。 此线程中讨论了提高允许连接数的方法: http://lists.rabbitmq.com/pipermail/rabbitmq-讨论/2011-May/013033.ht…
缺少 AMQP v.1.0 交换定义
我正在阅读有关 AMQP 0-9-1 实现的 RabbitMQ 规范,并按照教程页面中的示例进行操作,这些示例有助于解释交换和队列。 AMQP 规范 v.1.0 的最新主要版…
什么是 RabbitMQ 集群?
我已经在我的 ruby 项目中使用 RabbitMQ ( AMQP ) 一段时间了,无论如何我刚刚听说过 RabbitMQ 集群,任何人都可以简单地向我介绍一下它,我需要…
使用 Rabbitmq 或 Hornetq 实现高流量聊天组件
我正在为应用程序构建一个高流量聊天组件,并决定将其构建在消息队列之上,我将其范围缩小到这两个:Hornetq 和 Rabbitmq。 有人对哪个是更好的选择有…
为什么 RabbitMQ 不断从损坏的持久日志文件中中断?
我在 Django 应用程序中运行 Celery,并使用 RabbitMQ 作为消息代理。然而,RabbitMQ 总是这样崩溃。首先是我从 Django 得到的错误。跟踪大多不重要,…
在 Rackspace 云中排队
Closed. This question does not meet Stack Overflow guidelines. It is not currently accepting answers. 要求我们推荐或查找工具、库或最喜欢的…
rabbitmq什么时候使用tcp反压?
根据 Pika 文档“RabbitMQ 代理使用 TCP 背压来减慢客户端的速度,如果它传递信息的速度太快了。”我已经注册了一个背压回调,但尚未被调用。我的队列…
没有连接的 AMQP/RabbitMQ 通道什么时候会死亡?
我有一个简单的 RabbitMQ 测试程序,随机将消息排队,另一个读取它们,所有这些都使用 Spring-AMQP。如果消费者死亡(例如,在没有机会关闭其连接或通…
使用 AMQP RabbitMQ 进行 Spring Batch
我想使用 String Batch 从 RabbitMQ / AMQP 获取数据。 我想加载 100 条消息(或者如果 100 条没有出现,则表示超时后出现的消息数),然后将其放入列…
RabbitMQ:清除队列
我有一些队列,例如: online_queue = self._channel.queue_declare( durable = True, queue = 'online' ) 目前,我需要刷新该队列中的所有内容。 但…
在 CloudFoundry 中运行 RabbitMQ 时出现 NoSuchMethodError
我最近设置了一个 SpringSource CloudFoundry 微云实例,并尝试使用此处找到的 RabbitMQ(带代码)运行相当简短的消息传递示例: http://support.clou…