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.持久
-
编辑：在我写的时候解决了这个问题：P--我喜欢这样的解决方案。我想无论如何我都要把它贴出来，也许别人也会有同样的问题，找到我的解决办法。不关心点数/因果报应等等。我只是把整个事情写了出来，所以我想我应该把它和解决方案贴出来。 我有一个SQS FIFO队列。它使用的是一纸空文队列。以下是它的配置方式： 我有一个单一的生产者微服务，我有10个ECS映像运行作为消费者。 由于业务原因，我们在接近消息在队
-
为什么已经拥有了共享内存时需要消息队列呢？ 这将是多种原因，让我们将其分解为多个点来简化 - 据了解，一旦消息被一个进程接收到，它将不再可用于任何其他进程。 而在共享内存中，数据可供多个进程访问。 如果想使用小信息格式进行通信。 当多个进程同时进行通信时，共享内存数据需要同步保护。 使用共享内存的写入和读取频率很高，那么实现功能将会非常复杂。 在这种情况下不值得使用。 如果所有的进程不需要访问共享