Azure Service bus with AMQP-如何指定会话ID

Question

我正在尝试使用AMQP QPID java库向服务总线发送消息

我得到这个错误：

“需要为支持排序的分区主题的所有代理消息设置SessionId”

我的主题已打开强制消息排序（这是我得到这个错误的方式我猜）

使用Azure Service bus java库（而不是AMQP）时，我有以下功能：

这实体设置会话ID（…）；

使用AMQP库时，我看不到在要发送的消息上设置会话ID的选项

请注意，如果取消选中“强制消息排序”选项，消息将成功发送

这是我的密码

private boolean sendServiceBusMsg(MessageProducer sender,Session sendSession) {

        try {
            // generate message

            BytesMessage createBytesMessage = (BytesMessage)sendSession.createBytesMessage();

            createBytesMessage.setStringProperty(CAMPAIGN_ID, campaignKey);             
            createBytesMessage.setJMSMessageID("ID:" + bm.getMessageId());                                                    
      createBytesMessage.setContentType(Symbol.getSymbol("application/octet-stream"));

            /*message is the actual data i send / not seen here*/
            createBytesMessage.writeBytes(message.toByteArray());

            sender.send(createBytesMessage);

        } catch (JMSException e) {
    }

Answer 1

正如您所猜测的，有一个类似的SO线程Azure Service Bus topics partitioning验证了，通过setSupportOrderingwithfalse禁用功能强制消息排序可以解决此问题，但无法通过Azure Service Bus Java library完成，因为属性SupportOrdering现在处于私有状态。

您可以尝试按照@XinChen使用AMQP所说的设置属性组，如下所示。

服务总线会话，在AMQP 1.0协议中也称为“组”，是相关消息的无界序列。ServiceBus保证会话中消息的顺序。

希望有帮助。

Answer 2

SessionId属性映射到AMQP消息属性。group-id.Qpid JMS客户端应该将其映射到JMSXGroupID属性，因此请尝试以下操作，createBytesMessage。设置字符串属性（“JMSXGroupID”，“session-1”）