个人中心
文章发布
退出
作者热门文章
- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时，我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
25
4
我正在使用模块node-amqp通过后等待。
我可以向队列发布/订阅一些消息，但我想手动确认这些消息。
例如，我希望读取消息，但不确认消息，然后对此消息执行一些计算，然后发送 q.shift() 来确认消息并通过第二条消息。
我希望手动使用确认。
实际上我有一个函数允许使用标志 {ack: false} 进行订阅然后我有一个函数可以手动创建 q.shift() (如文档中所述)。
但是当我发布 2 条消息，然后我阅读 2 条消息时，在没有确认的情况下，我看到了 2 条消息。但我希望订阅者重复最初收到的相同消息，直到我不确认为止。
如何使用这些方法？
最佳答案
我知道这个问题有点老了，只是在寻找问题时看到的
您必须将“ack-flag”设置为 true，以确保您手动确认该消息。 ack: false 表示确认将自动完成
queue.subscribe({ack: true}, ...
关于javascript - 使用 node-amqp 模块在 Node.js 中手动确认，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/7387298/
25
4
0
在 Spring AMQP 项目中， 如果 messageProperties 没有 messageId，它们总是创建 messageId。 像这样.. if (this.createMessageI
我不确定我对 errorHandler 和 returnExceptions 的理解是否正确。 但这是我的目标:我从 App_A 发送了一条消息，使用 @RabbitListener 在 App_B
就目前而言，这个问题不适合我们的问答形式。我们希望答案得到事实、引用资料或专业知识的支持，但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开，visit the
我们希望将大型机放在总线上。我相信是AS400。为此，我想让 CICS 大型机向代理发送 AMQP 消息。有几十个AMQP客户端，包括JMS客户端。我对大型机上可能发生的事情了解不够，无法判断是否可以
我们希望将大型机放在公共(public)汽车上。我相信它是AS400。为此，我想让 CICS 大型机向代理发送 AMQP 消息。有几十个 AMQP 客户端，包括 JMS 客户端。我不太了解大型机上的可
我即将实现一个基于 PHP 的系统，该系统使用 RabbitMQ。我可以看出那里有 2 个成熟的库:PECL AMQP和 php-amqp . 我将同时为客户端和工作人员使用 PHP。 有人对这两个库
我正在使用 RabbitMQ 和 ruby-amqp与 Rails。当 Controller 收到消息时，我执行以下操作: def create AMQP.start("amqp://localh
我有两个困惑。 1.如果消息监听器抛出RuntimeException，SimpleMessageListenrContainer会停止吗？2.如果SimpleMessageListenerConta
我们在绑定(bind)到 Rabbit MQ 实例的 Java 应用程序的日志中遇到以下异常。 这是必须要注意的事情，表示Spring AMQP的实现中存在问题，还是可以忽略的事情？在后一种情况下，此
场景:微服务从 RabbitMQ 队列中获取消息，将其转换为对象，然后微服务对外部服务进行 REST 调用。 它将处理成千上万条这样的消息，如果我们知道外部 Rest 服务已关闭，有没有办法告诉我的消
我有一个使用带有 webflux 的 Boot 2.0 的应用程序，并且有一个端点返回 ServerSentEvent 的 Flux。这些事件是通过利用 spring-amqp 从 RabbitMQ
我正在尝试使用 streadway/amqp 连接到 RabbitMQ 总线Go 的驱动程序。我正在处理重新连接例程，为此，我有一个 rabbitMQConsume 函数调用 rabbitMQConn
我正在尝试通过 SSL 连接到 RabbitMQ。我遵循了此处链接的 RabbitMQ SSL 文档 https://www.rabbitmq.com/ssl.html根据 RabbitMQ SSL
这些 amqp 客户端库之间有什么区别？哪一个是最推荐的？主要区别是什么？ 最佳答案 我会推荐 amqp.node和 bramqp通过 node-amqp。 node-amqp 有很多错误并且维护不善
我得到的错误: 2019-12-09 06:39:33.189 ERROR 107132 --- [http-nio-8082-exec-5] o.a.c.c.C.[.[.[/].[dispatche
所以我已经让 MQTT -> MQTT 和 AMQP -> AMQP 工作；不过，MQTT -> AMQP 的翻译似乎在某处不起作用。这是我的测试，如果我的“监听器”也在使用 paho 的 MQTT
我得到的错误: 2019-12-09 06:39:33.189 ERROR 107132 --- [http-nio-8082-exec-5] o.a.c.c.C.[.[.[/].[dispatche
几天前我问了同样的问题:Unable to "Peek" messages from an Azure Service Bus Queue using AMQP and Node 。我再次问同样的问题
我有一个当前与 RabbitMQ 集成的组件。我想将 RabbitMQ 替换为 Azure Event Hub，因为我们现在位于云中。 AMQP 0.9.1 与 AMQP 1.0 兼容吗？交换会无缝进
我有一个当前与 RabbitMQ 集成的组件。我想将 RabbitMQ 替换为 Azure Event Hub，因为我们现在位于云中。 AMQP 0.9.1 与 AMQP 1.0 兼容吗？交换会无缝进
我是一名优秀的程序员,十分优秀！