使用JMS为Azure Service Bus计划消息

Question

我想使用JMS向Azure服务总线发送预定消息。我的代码基于org.apache.qpid.jms.message.JmsMessage。我已经为给定的问题找到了一个解决方案，但它使用org.apache.qpid.proton.message.Message，其中包含. getMessageAnnotions（），它允许编辑消息注释并添加Azure服务总线正确识别和处理的一些属性。我的消息iml缺少那个方法。

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

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

所以当我向队列发送消息时，我可以在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上的Service Bus Explorer上查看它时，它会在浏览器控制台中抛出错误，操作将永远持续。我猜设置该属性会对服务总线产生一些影响。我还尝试发送一个以字符串形式显示日期的地图（使用Azure使用的日期格式），如“ScheduledEnqueueTimeUtc”，“2021 3月25日星期四12:54:00 GMT”，但服务总线也会将其识别为错误（窥视会一直持续，浏览器控制台中会抛出错误）。

我尝试过设置字符串属性，例如x-opt-调度-enqueue-time或x-ms-调度-enqueue-time，我在SO上的其他线程中找到了这些属性，但它们都不适用于我的示例。

我看到Microsoft为Java提供了一些库来与Azure Service Bus通信，但我需要在代码中保持与云提供商的独立性，并且不包括任何额外的lib。

是否有使用包org.apache.qpid.jms.message.JmsMessage中的JMS消息实现为Azure服务总线设置BrokerProperties的示例？

Answer 1

我的团队目前面临着同样的问题。

我们发现SchduledEnqueueTimeUtc属性是在MessageAnnotationsMap中设置的。不幸的是，JMS使用的org.apache.qpid.jms.provider.amqp.message.AmqpJmsMessageFacade将getter和setter设置为包私有的。但是我们发现您可以使用setTracingAnnoection（String key， Object value）方法。

例子：

public void sendDelayedMessage() {
    final var now = ZonedDateTime.now();
    jmsTemplate.send("test-queue", session -> {
        final var tenMinutesFromNow = now.plusMinutes(10);
        final var textMessage = session.createTextMessage("Hello Service Bus!");
        ((JmsTextMessage) textMessage).getFacade().setTracingAnnotation("x-opt-scheduled-enqueue-time", Date.from(tenMinutesFromNow.toInstant()));
        return textMessage;
    });
    log.info("Sent at: " + now);
}

非常感谢我的队友！！