ibm集成总线如何通过java计算节点覆盖JMSReceive节点的MessageCorrelationIDSelector
我需要从JMS队列中读取消息,并根据流中间的JMsCalpRealID来过滤消息。所以我用了JMSReceiveNode。JMSCorrelationID是动态的。因此,我试图通过java计算节点超越MessageCorrelationIDSelector,如下所示。我在本地环境中添加了correlationid树
我的java计算节点代码:
localEnv.getRootElement().createElementAsLastChild(MbElement.TYPE_NAME, "JMS", null).
createElementAsLastChild(MbElement.TYPE_NAME, "Receive", null).
createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "MessageCorrelationIDSelector", dynamicID);'
但我发现JMS Destination未发现异常。如果我从本地环境中删除本地MessageCorrelationIDSelector,它可以正常工作
当地环境树如下图所示
'LocalEnvironment
JMS
Receive MessageCorrelationIDSelector:CHARACTER:123457
共 (0) 个答案