Spring AMQP RabbitMQ RPC-包含一些不期望响应的消息的队列
我正在尝试创建一个优先级RPC队列，它可以接受一些期望响应的消息和一些不期望响应的消息。我面临的问题是，当我使用convertAndSend发送消息时，我会收到一个错误，上面写着“org.springframework.amqp.AmqpException:无法确定ReplyTo消息属性值：请求消息不包含reply to属性，并且没有设置默认的响应交换。”我知道问题在于RPC队列需要响应，而消息只是停留在队列上，但对于这些消息，我不想要/需要响应。你知道我该如何解决这个问题吗？
谢谢，布莱恩
共有1个答案
这个链接中推荐的一个解决方案对我很有用：单队列，多个@RabbitListener，但不同的服务。基本上，我有一个带有RabbitListener的类，以及带有RabbitHandler的不同方法
-
我将与一起使用中的这个库。所有使用者均为,所有队列均为（4小时）。 我有很多队列没有任何挂起的ack，但仍然保存着数百条消息。此外，队列不会在应该过期时过期，这将在几天后产生性能问题。我没有找到任何理由来解释为什么消息在ack处理之后仍然在队列中。 谢谢 管理工具中的一些快照：
-
问题内容： 希望在我正在使用node.js构建的小型Web应用程序中使用消息队列。我看了resque，但不确定是否合适。目标是基于套接字和后端的其他客户端操作将通知推送到客户端。我可以只用socketio来做到这一点，但我认为也许适当的消息队列可以使这个清理器更干净，而我不必重新发明轮子。 有哪些选择？ 问题答案： 您可以将redis与快速的node_redis客户端一起使用。它甚至具有内置的pu
-
因此，我使用Spring integration链接JMS和ActiveMQ，如下所示：- 如何使其工作，以便发送到此队列并从中接收消息？请帮忙。
-
本文向大家介绍Python的消息队列包SnakeMQ使用初探，包括了Python的消息队列包SnakeMQ使用初探的使用技巧和注意事项，需要的朋友参考一下 一、关于snakemq的官方介绍 SnakeMQ的GitHub项目页：https://github.com/dsiroky/snakemq 1.纯python实现，跨平台 2.自动重连接 3.可靠发送--可配置的消息方式与消息超时方式 4.持久
-
为什么已经拥有了共享内存时需要消息队列呢？ 这将是多种原因，让我们将其分解为多个点来简化 - 据了解，一旦消息被一个进程接收到，它将不再可用于任何其他进程。 而在共享内存中，数据可供多个进程访问。 如果想使用小信息格式进行通信。 当多个进程同时进行通信时，共享内存数据需要同步保护。 使用共享内存的写入和读取频率很高，那么实现功能将会非常复杂。 在这种情况下不值得使用。 如果所有的进程不需要访问共享
-
一、消息模型 点对点 发布/订阅 二、使用场景 异步处理 流量削锋 应用解耦 三、可靠性 发送端的可靠性 接收端的可靠性 参考资料 一、消息模型 点对点 消息生产者向消息队列中发送了一个消息之后，只能被一个消费者消费一次。 发布/订阅 消息生产者向频道发送一个消息之后，多个消费者可以从该频道订阅到这条消息并消费。 发布与订阅模式和观察者模式有以下不同： 观察者模式中，观察者和主题都知道对方的存在；