小编Mat*_*tti的帖子

我想使用 JMS 将计划消息发送到 Azure 服务总线。我的代码是基于org.apache.qpid.jms.message.JmsMessage. 我找到了针对给定问题的一种解决方案，但它使用org.apache.qpid.proton.message.Messagewhich has .getMessageAnnotations()，它允许编辑消息注释并添加一些由 Azure 服务总线正确识别和处理的属性。我的消息 impl 缺少该方法。

我在官方文档和node.js 中的实现中发现，要使用Azure 服务总线安排消息，您需要发送BrokerProperties/brokerProperties具有有效json 的标头。其他标头/属性将被标记为Customer properties并被 Azure 服务总线忽略。

关于 JMS 的官方 azure 文档ScheduledEnqueueTimeUtc表示JMS API 不正式支持该设置。但可以通过手动设置属性来实现。

因此，当我将消息发送到队列时，我可以在 lambda 中对其进行后期处理并设置一些属性：

jmsTemplate.convertAndSend(queue, payload, message -> {
    var date = Date.from(ZonedDateTime.now(ZoneId.of("UTC")).plus(delay, ChronoUnit.MILLIS).toInstant());
    var brokerProps = Map.of("ScheduledEnqueueTimeUtc", date.toGMTString());
    message.setStringProperty(
        "brokerProperties",
        objectMapper.writeValueAsString(brokerProps)
    );
    return message;
});

但这不起作用。消息到达队列，但当我尝试在 Azure 上的服务总线资源管理器上查看它时，它会在浏览器控制台中抛出错误，并且该操作将永远持续。我想设置该属性brokerProperties会对服务总线产生一些影响。我还尝试发送带有日期作为字符串的地图（带有Azure使用的日期格式）"ScheduledEnqueueTimeUtc", "Thu, 25 Mar 2021 12:54:00 GMT"，但它也被服务总线识别为错误（窥视永远持续，并在浏览器控制台中引发错误） 。

我尝试设置类似x-opt-scheduled-enqueue-time或x-ms-scheduled-enqueue-time …