WebSphere MQ、WebSphere MQ Everyplace 和 SCADA 消息包括 MQMD 头。您可以使用 JavaCompute 节点引用 MQMD 中的字段,并更新它们。
public void addMqmd(MbMessage msg) throws MbException { MbElement root = msg.getRootElement(); // create a top level 'parser' element with parser class name MbElement mqmd = root.createElementAsFirstChild("MQHMD"); // specify next parser in chain mqmd.createElementAsFirstChild(MbElement.TYPE_NAME_VALUE, "Format", "XMLNS"); }