如何在 JMS:selector 中使用 Mule 表达式

Question

我检查了之前的几个讨论，但找不到答案。

我正在尝试使用 JMS 后台通道 (http://www.whishworks.com/blog/synchronous-communication-using-jms-back-channel) 实现同步通信。除了该站点中提到的内容外，我还需要根据动态 Id 从入站队列中过滤掉消息。

以下是我的 mule 流：

<flow name="serverFlow" >
    <jms:inbound-endpoint doc:name="REQUEST" queue="REQUEST.QUEUE" connector-ref="jmsConnector">
            <jms:selector expression="MULE_CORRELATION_ID='#[sessionVars.myCorrelationId]'"/>
    </jms:inbound-endpoint>     

    <set-payload value="#[payload] + Hello World from Receiver" doc:name="Set Payload" />

    <jms:outbound-endpoint doc:name="REPLY" queue="REPLY.QUEUE" connector-ref="jmsConnector" />
</flow>

 <flow name="mainFlow" >
    <http:listener config-ref="HTTP_Listener_Configuration" path="/jms" allowedMethods="GET" doc:name="HTTP"/>
    <set-session-variable variableName="myCorrelationId" value="#[System.currentTimeMillis().toString()]" doc:name="Set Correlation ID"/>       
   <set-payload value="New message sent from Mule - mainFlow at #[new Date()]" doc:name="Set Message"/>        
   <set-property propertyName="MULE_CORRELATION_ID" value="#[sessionVars.myCorrelationId]" doc:name="Property"/>  
    <request-reply doc:name="Request-Reply">
        <jms:outbound-endpoint doc:name="REQUEST" connector-ref="jmsConnector" queue="REQUEST.QUEUE"/>
        <jms:inbound-endpoint doc:name="REPLY" connector-ref="jmsConnector" queue="REPLY.QUEUE"/>
    </request-reply>        
    <logger message="Reply to sender: #[message]" level="WARN" doc:name="Logger" />
</flow>

如果我尝试像“”这样的静态值，它会起作用。但是，如果我尝试使用 MEL 的动态 ID，它就不起作用了。 jms 选择器表达式中的 MEL 不起作用。消息以未读状态保留在队列中。我使用日志查看在 mainFlow 设置时 MULE_CORRELATION_ID 是什么，发现在队列中未读的消息中设置了相同的值。所以，我想 MULE_CORRELATION_ID 的设置方式没有错。唯一的问题是 MEL 在 jms:selector.

内不工作

能否请您帮助如何让 MEL 在 JMS 选择器中工作？

非常感谢。

Answer 1

MEL 在 selector 中运行良好，但它的使用非常有限。当 JMS selector 创建时，Mule 没有可用的运行中事件，因此 none 的事件绑定数据（包括会话）可用。

要 select 一条非常特殊的消息，您需要使用 JMS message requester，用所需的 select 构造，或者，如：

jms://REQUEST.QUEUE?selector=MULE_CORRELATION_ID%3D'#[sessionVars.myCorrelationId]'

Answer 2

这是基于大卫建议的可行解决方案。我这里用的是wmq（不是jms）

<mulerequester:config name="Mule_Requester" doc:name="Mule Requester"/>

<flow name="mainFlow">
    <http:listener config-ref="HTTP_Listener_Configuration" path="/test" allowedMethods="GET" doc:name="HTTP"/>        
    <set-payload value="My Message" doc:name="Set Message"/>  
    <set-property propertyName="JMSCorrelationID" value="12345" doc:name="Property"/>
    <set-session-variable variableName="myCorrelationId" value="ID:313233343500000000000000000000000000000000000000" doc:name="Set Correlation ID"/>
    <!--313233343500000000000000000000000000000000000000 is the MQMD CorrelationId for 12345. This is set by IBM MQ   -->
    <logger message="The Message to REQUEST QUEUE: #[message]" level="WARN" doc:name="Logger"/>        
    <wmq:outbound-endpoint  queue="REQUEST.QUEUE" connector-ref="wmqConnector" doc:name="OUT"/>
    <mulerequester:request config-ref="Mule_Requester" resource="wmq://REPLY.QUEUE?selector=JMSCorrelationID%3D'#[sessionVars.myCorrelationId]'" doc:name="Mule Requester" timeout="120000"/>   
    <logger message="Final Response: #[message]" level="WARN" doc:name="Logger"/>         
</flow>

请注意，我使用 MQVE 手动将消息从请求队列移动到回复队列以进行测试。实时，将由另一个程序完成。

如何在 JMS:selector 中使用 Mule 表达式

How to use Mule Expression in JMS:selector

mule

mule-el

mule-component

anypoint-studio