天天看点

MQ消息流中JavaCompute节点如何添加消息头(MQRFH2)属性

1.获取MB的对应节点MQRFH2。

2.根据节点树获取相应的属性,然后再设置该属性的属性值。

     MbElement mqmdElement ;    //定义获取消息节点树的对象

     mqmdElement = root.getFirstElementByPath("/MQMD/Expiry");    //获取消息头超时属性

     mqmdElement.setValue(120);    //设置超时时间,可以自由定义,以十分之一秒为单位

     mqmdElement = root.getFirstElementByPath("/MQMD/Report");   //获取报文消息头的报告消息属性

     mqmdElement.setValue(14680064);  //表示消息超时自动产生报告消息,即MQRO_EXPIRATION_WITH_FULL_DATA  // 设置获取报文消息头的报告消息属性值

     mqmdElement = root.getFirstElementByPath("/MQMD/ReplyToQ");    //获取报文消息头的报告消息超时后要发送到的队列

     mqmdElement.setValue(ConstantDef.QUEUE_COMMON_COMMON_ONLINETIMEOUT_ESB);    //表示未取出报告消息超时后要发送到的队列