java - 我们如何使用java对azure服务总线队列中存在的消息添加延迟？

Question

我正在尝试使用 java 对服务总线队列上存在的消息添加延迟。这样在延迟之后，函数应用程序就可以使用相同的消息进行处理。

任何人都可以向我推荐示例代码或相同的链接吗？

Answer 1

据我所知，不可能向服务总线队列中已存在的消息添加延迟。

每个服务总线消息都有一个 ScheduledEnqueueTimeUtc当消息发送到队列时可以设置的属性，这将确保该消息仅在此时出现在队列中，以便可以使用它。

但是，您无法更改现有消息的此属性。您可以做的是重新提交消息(实质上创建原始消息的副本)，并为 ScheduledEnqueueTimeUtc 属性设置所需的值。请查看public CompletableFuture scheduleMessageAsync(IMessage message, Instant scheduledEnqueueTimeUtc)了解更多详情。