<flow name="readqueueFlow1" doc:name="readqueueFlow1" >
<jms:inbound-endpoint queue="MyTestQueue" connector-ref="Active_MQ-Priority" doc:name="JMS">
<jms:selector expression="JMSCorrelationID=’353’" />
</jms:inbound-endpoint>
</flow>
它可以工作,但是当我尝试使用以下一个时,它没有部署
<!-- When we don't provide single quote it is failing in deployment -->
<jms:selector expression="JMSCorrelationID='#[flowVars.reqId]'" />
<!-- Payload contains reqId, when we provide it in single quote, it is assuming as a constant -->
<jms:selector expression="JMSCorrelationID='#[payload]'" />
我想这是你的答案:- 在 Mule 3 中的 JMS 选择器中使用表达式
还有一件事,您不能使用 #[flowVars.reqId]
来动态获取jms:selector
值,因为流变量范围仅限于流......而是使用会话变量,例如 #[sessionVars.reqId]
..
您的流程将修改如下:-
<flow name="readqueueFlow1" >
<jms:inbound-endpoint queue="StudioOUT" connector-ref="Active_MQ" doc:name="JMS"/>
<scripting:component>
<scripting:script engine="groovy"><![CDATA[
def jmsMessages = []
for (def muleMessage = muleContext.client.request("jms://MyTestQueue?selector=JMSCorrelationID%3D'"+ sessionVars['reqId'] +"'", -1L);
muleMessage != null;) {
[] << muleMessage.payload
}
jmsMessages
]]></scripting:script>
</scripting:component>
<logger level="INFO" message="#[message.payload]" doc:name="Logger"/>
</flow>
您可以在此处看到消息使用 Groovy 脚本发送到队列,我使用了会话变量而不是流变量
jms:selector expression="putOnQueueTime> ABC "
可以在 JMS 入站中使用上述表达式。