RabbitMQ在ACK后依次接收消息
我希望通过RabbitMQ获得以下模式以“顺序”接收消息。我使用Node.js框架作为消费者。
假设队列中有3条消息,我需要这样的模式：
我的队列是持久的，需要ACK。我是不是缺了什么？
请救命！
共有1个答案
找到答案了。我得设置预取计数。在上面的场景中，必须将预取设置为1。
-
此处的文档：http://www.rabbitmq.com/semantics.html 声明当信道关闭时，它被重新分配以进行传递 消息可以使用以requeue参数(Basic.recover、Basic.reject和Basic.NACK）为特征的AMQP方法返回到队列，也可以由于在保留未确认消息时通道关闭而返回到队列。对于2.7.0之前的RabbitMQ版本，这些场景中的任何一个都会导致消息在
-
在spring-AMQP中，有可能以某种方式推迟监听来自某个特定队列的消息吗？ 在我的用例中，我有一个服务，它必须侦听两个RabbitMQ队列上的消息。第一个专用于此服务，第二个用于my service的多个实例（运行在不同的机器上）的负载平衡作业。 我的statup服务通过第一个队列接收配置并自我配置。只有在配置之后，才允许处理第二个队列中的“标准”作业--而不是在配置之前。 我怎样才能做到这一
-
我有以下兔子听者： 我需要将listener配置为在它处理一条消息后等待15分钟，然后再接收下一条消息。不需要在此方法中等待。我所需要的只是在处理完一条后不接收任何消息。可以通过来完成，但我不确定这是否是实现这一点的最佳方法。对于这种情况有没有rabbitmq的配置？
-
我的示例接受google pub/sub，记录它并将ack发送回 配置： NotificationHandler： 线程转储： 行： 但ThreadExecutor未执行deliverMessageTask。 在我看来，它看起来像是库中的一个bug，但可能是库误用。无论如何，我正在寻找任何解决方案/变通办法来避免这种情况。 我使用: spring-boot springCloudVersion=
-
我已经安装了一个XMPP服务器，并在android上使用smack做了一个客户端应用程序，一切都很好，但我正在更新的手机上测试应用程序，它不再工作了。 Android杀死了等待消息的服务（当用户关闭应用程序时杀死服务），我一直在读，人们说我应该使用FCM，但我想使用我自己的消息服务器，因为我在XMPP服务器上添加了一些特殊的用户管理逻辑。我不知道我是否可以使用FCM sdk来获取我自己的消息并从那