骡子接头

Question

我是骡子和JMS的新手。只是试图弄清楚如何使用连接器添加JMSendpoint。是否提供了 Mule 提供的任何 JMS 实现，或者我是否需要使用外部 JMS 提供程序。

Answer 1

将另一个 HTTP 连接器拖放到画布中以创建新流。为流指定一个新名称后主题消息流。在“HTTP 属性”视图中，将连接器配置设置为现有HTTP_Listener_Configuration。将路径设置为 /jms，将允许的方法设置为 GET。将另一个 JMS 连接器拖放到流的流程部分中。在 JMS 属性视图中，选择主题并将其设置为 jms 连接。将连接器配置设置为现有Active_MQ。如果您看到属性“操作是必需的”警告，请忽略它。在 HTTP 和 JMS 连接器终端节点之间添加“设置有效负载”转换器。在“设置负载属性”视图中，将显示名称更改为“设置消息”，并将值设置为消息查询参数。将断点添加到“设置负载”转换器。在“设置负载”转换器之后添加属性转换器。在“属性”视图中，将显示名称更改为“设置名称”。选择“设置属性”，然后将名称设置为名称，将值设置为你的名称。注： 如果您愿意，可以改为将其设置为查询参数。保存文件以重新部署应用程序并发出 http://localhost:8081/jms?message=Hello 的请求。查看控制台;;您应该看到显示您的姓名和消息 - 以及您同学的姓名和消息。

Answer 2

以下是骡子 JMS 连接器的 ActiveMQ 使用指南。

Mule ActiveMQ集成http://www . mulesoft . org/documentation/display/mule 3 user/ActiveMQ集成

这应该有帮助。

Answer 3

一个简单的例子是:-

<jms:activemq-connector name="Active_MQ" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ"/>

要将消息发送到队列 ：-

<flow name="JmsSendFlow" doc:name="JmsSendFlow" >
 <http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8082" path="mainData" doc:name="HTTP"/>
 <set-payload value="Test Data" />
 <jms:outbound-endpoint queue="StudioOUT" connector-ref="Active_MQ" doc:name="JMS"/>
</flow>

从队列中接收消息:-

<flow name="JmsReceiveFlow" doc:name="JmsReceiveFlow" >
 <jms:inbound-endpoint queue="StudioOUT" connector-ref="Active_MQ1" exchange-pattern="one-way"/>
 <logger message="Message received#[message.payload]" level="INFO" doc:name="Logger"/>
</flow>

有关 JMS 的更多信息：- http://blogs.mulesoft.com/dev/newbie/mule-school-jms-tutorial/