将 AMQP 与 JTA 结合使用
有没有在CMT/JTA环境中使用AMQP客户端的好例子?我知道 AMQP 支持事务消息传递,但我不知道它如何与 JTA 保持一致。 到目前为止,我已成功设置 Apache…
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 集群,任何人都可以简单地向我介绍一下它,我需要…
没有连接的 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' ) 目前,我需要刷新该队列中的所有内容。 但…
使用 Thin 作为 Web 服务器时从 Resque 工作线程访问 AMQP 连接
尝试解决使用 resque 作业处理入站 AMQP 消息时出现的问题。 我使用初始化程序在应用程序启动时设置消息使用者,然后将收到的消息提供给重新队列作业…
PHP 致命错误:类“AMQPConnection”未找到
我已经看过这个问题。这表明未安装 AMQP PECL 扩展。但是,我已经成功安装了 RabbitMQ 以及构建的 PECL AMQP 扩展。以下是 phpinfo() 的输出。 您可以…
测试面向消息的中间件 (MOM) 解决方案的性能和可扩展性的最佳实践是什么?
Closed. This question is opinion-based. It is not currently accepting answers. 想要改进这个问题?更新问题,以便可以通过编辑这篇文章用事实和…