我有一个带有JMS请求-应答块的Mule(3.5)流。我看到所有进入回复队列的消息都被自动消耗掉了。我想处理到达jms回复队列的消息。到目前为止,我已经尝试了jms:选择器和jms请求器模块,但没有运气。有什么办法可以做到这一点吗?
代码:<mule>
<flow name="main" doc:name="main">
<http:inbound-endpoint exchange-pattern="request-response" host="localhost" path="test" port="2000" doc:name="HTTP"/>
<logger message="starting main flow" level="INFO" doc:name="Logger"/>
<request-reply storePrefix="mainFlow">
<jms:outbound-endpoint queue="StudioIN" connector-ref="Active_MQ1" exchange-pattern="one-way"/>
<jms:inbound-endpoint queue="StudioOUT" connector-ref="Active_MQ1" exchange-pattern="one-way">
<property key="selector" value="JMSCorrelationID='#[message.correlationId]'"/>
</jms:inbound-endpoint>
</request-reply>
</flow>
<flow name="worker" doc:name="worker">
<jms:inbound-endpoint queue="StudioIN" connector-ref="Active_MQ1" doc:name="JMS"/>
<async doc:name="Async">
<logger message="starting worker task(s) .... Payload: #[payload], Request: #[message.inboundProperties['http.request']]" level="INFO" doc:name="Logger"/>
<scripting:component doc:name="thread-sleep(10s)">
<scripting:script engine="Groovy">
System.out.println "about to sleep @ time" + System.currentTimeMillis()
Thread.sleep(10000);
System.out.println "done sleeping @ time" + System.currentTimeMillis()
</scripting:script>
</scripting:component>
<logger message="finishing up worker task(s) ...." level="INFO" doc:name="Logger"/>
</async>
</flow>
</mule>
我想处理任何来回复队列StudioOUT。有什么合适的方法可以做到这一点吗?
首先在中删除<property key="selector" value="JMSCorrelationID='#[message.correlationId]'"/>
然后尝试以下操作,根据入站JMS端点中的过滤器使用消息:-
<jms:inbound-endpoint queue="StudioOUT" connector-ref="Active_MQ1" exchange-pattern="one-way">
<jms:selector expression="JMSCorrelationID= #[message.correlationId]" />
</jms:inbound-endpoint>
如果您想在出站JMS端点中设置消息属性并将其发送到出站JMS queue,请尝试以下操作:
<jms:outbound-endpoint queue="StudioOUT" connector-ref="Active_MQ" doc:name="JMS">
<jms:object-to-jmsmessage-transformer name="ObjectToJmsMessage" />
<message-properties-transformer>
<add-message-property key="CorrelationID" value="#[message.correlationId]"/>
</message-properties-transformer>
</jms:outbound-endpoint>
更新流:- 要为特定类型选择JMS消息,我们需要首先将其设置在队列中…例如,假设我们只需要选择和使用优先级为7的JMS消息。现在让我们将消息发送到JMS队列,优先级为7 .
因此在JMS出站端点
中设置以下内容<jms:outbound-endpoint queue="StudioOUT" connector-ref="Active_MQ" doc:name="JMS">
<jms:object-to-jmsmessage-transformer name="ObjectToJmsMessage" />
<message-properties-transformer>
<add-message-property key="Priority" value="7"/>
</message-properties-transformer>
</jms:outbound-endpoint>
现在这将发送消息到队列,JMS优先级为7 ..
现在您可以从JMS优先级为7的队列中使用这些消息。剩余的消息将被忽略,不会被使用。因此,现在在JMS入站端点中使用以下内容来过滤消息:-
<jms:inbound-endpoint queue="StudioOUT" connector-ref="Active_MQ1" exchange-pattern="one-way">
<jms:selector expression="JMSPriority = 7" />
</jms:inbound-endpoint>
这里只会使用优先级为7的消息。现在可以配置入站以从队列中选择特定类型的消息。但是要确保特定类型的消息(这里是优先级为7的消息)存在于JMS队列中。所以. .为此,您需要使用我现在展示的JMS出站端点向JMS队列发送一些消息。
在将消息发送到JMS出站时使用以下命令复制关联ID
<jms:outbound-endpoint queue="StudioIN" connector-ref="Active_MQ1" exchange-pattern="one-way">
<copy-properties propertyName="*"></copy-properties>
<jms:outbound-endpoint>
希望这对你有帮助。