带有 AMQP 的 Azure 服务总线 - 如何指定会话 ID

Question

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

我收到此错误：

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

我的主题打开了“强制消息排序”（我猜这是我收到此错误的方式）

当使用 Azure 服务总线 java 库（而不是 AMQP）时，我有这个功能：

this.entity.setSessionId(...);

使用 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

SessionId 属性映射到 AMQP 消息 properties.group-id。Qpid JMS 客户端应该将其映射到 JMSXGroupID 属性，因此请尝试以下操作， createBytesMessage.setStringProperty("JMSXGroupID", "session-1");