在 JMS 中设置 IBM MQ 定制属性不起作用

Question

尝试在发送消息时在 JMS 中设置 IBM MQ 定制属性。它不起作用。

我正在 JMS/Apache camel 中寻找以下等效项。

mQMessage.setStringProperty( "customProperty", "123" );

尝试了以下 3 个选项：

1) exchange.getIn().setHeader( "customProperty", "123" );
2) exchange.getIn().setProperty( "customProperty", "123" );
3) mQQueueConnectionFactory.setStringProperty( "customProperty", "123" );

以下读取属性的代码会引发错误，因为该属性似乎不存在。 mQMessage.getStringProperty("messageGlobalSequenceNumber")

抛出以下错误：

com.ibm.mq.MQException: MQJE001: Completion Code '2', Reason '2471'.
        at com.ibm.mq.MQMessage.getProperty(MQMessage.java:5694)
        at com.ibm.mq.MQMessage.getStringProperty(MQMessage.java:6949)
        at com.ibm.mq.MQMessage.getStringProperty(MQMessage.java:6925)
...

Answer 1

您确定您尝试检索的属性确实存在于该消息中吗？因为原因代码 2471 (MQRC_PROPERTY_NOT_AVAILABLE) 明确表示指定的属性不存在。

在JMS（针对IBM MQ）中创建消息属性的正确方法如下：

/**
 * Send a message to a queue.
 * @param session
 * @param myQ
 * @throws JMSException
 */
private void sendMsg(QueueSession session, Queue myQ) throws JMSException
{
   QueueSender sender = null;

   try
   {
      TextMessage msg = session.createTextMessage();
      msg.setText("This is a test message.");
      msg.setStringProperty("MyProp01", "somevalue");

      sender = session.createSender(myQ);
      sender.send(msg);
   }
   finally
   {
      try
      {
         if (sender != null)
            sender.close();
      }
      catch (Exception ex)
      {
         System.out.println("sender.close() : " + ex.getLocalizedMessage());
      }
   }
}

您是否使用 MQ 工具检查消息的属性值？我运行了上面的代码，然后使用MQ Visual Edit 检查了队列中的消息，这是一个屏幕截图：

或显示命名属性（又名消息属性）的已打开选定消息的屏幕截图：