Mule 消费 JMS 主题消息
Mule consuming JMS topic message
我的流程是:
<flow name="activemqFlow3" doc:name="activemqFlow3">
<http:inbound-endpoint exchange-pattern="request-response" host="${hostname}" port="${port}" path="producetopic" doc:name="HTTP"/>
<set-payload value="===TOPIC===" doc:name="Set Payload"/>
<jms:outbound-endpoint topic="sfdc" connector-ref="Active_MQ" doc:name="JMS" />
</flow>
<flow name="activemqFlow4" doc:name="activemqFlow4">
<jms:inbound-endpoint doc:name="JMS" connector-ref="Active_MQ" topic="sfdc"/>
<logger message="===#[message.payload]" level="INFO" doc:name="Logger"/>
</flow>
AcitveMQ 控制台在主题部分下显示一个消费者,但是一旦点击 http://localhost:9001/producetopic url. When I go to AcitveMQ console http://localhost:8161/admin/topics.jsp 并选择 sfdc 主题,我就不会在 Anypoint Studio 控制台中立即收到响应,发送按钮将在 Anypoint Studio 控制台中收到响应。
为什么我发布主题时不显示立即response/subscribe?
EDIT
全局元素:
<jms:activemq-connector name="Active_MQ" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ"/>
控制台:
INFO 2015-05-15 07:56:21,820 [main] org.mule.module.launcher.DeploymentDirectoryWatcher:
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
+ Mule is up and kicking (every 5000ms) +
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
INFO 2015-05-15 07:56:29,081 [[sfdc].activemqFlow4.stage1.02] org.mule.api.processor.LoggerMessageProcessor: ======TOPIC===
这是我的错误,服务器正在控制台中显示数据。为了更好地理解,我修改了订阅者记录器以区分来自发布者的数据。
<logger message="==Subscriber=#[message.payload]====" level="INFO" doc:name="Logger"/>
现在控制台显示:
==Subscriber====TOPIC=======
我的流程是:
<flow name="activemqFlow3" doc:name="activemqFlow3">
<http:inbound-endpoint exchange-pattern="request-response" host="${hostname}" port="${port}" path="producetopic" doc:name="HTTP"/>
<set-payload value="===TOPIC===" doc:name="Set Payload"/>
<jms:outbound-endpoint topic="sfdc" connector-ref="Active_MQ" doc:name="JMS" />
</flow>
<flow name="activemqFlow4" doc:name="activemqFlow4">
<jms:inbound-endpoint doc:name="JMS" connector-ref="Active_MQ" topic="sfdc"/>
<logger message="===#[message.payload]" level="INFO" doc:name="Logger"/>
</flow>
AcitveMQ 控制台在主题部分下显示一个消费者,但是一旦点击 http://localhost:9001/producetopic url. When I go to AcitveMQ console http://localhost:8161/admin/topics.jsp 并选择 sfdc 主题,我就不会在 Anypoint Studio 控制台中立即收到响应,发送按钮将在 Anypoint Studio 控制台中收到响应。 为什么我发布主题时不显示立即response/subscribe?
EDIT
全局元素:
<jms:activemq-connector name="Active_MQ" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ"/>
控制台:
INFO 2015-05-15 07:56:21,820 [main] org.mule.module.launcher.DeploymentDirectoryWatcher:
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
+ Mule is up and kicking (every 5000ms) +
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
INFO 2015-05-15 07:56:29,081 [[sfdc].activemqFlow4.stage1.02] org.mule.api.processor.LoggerMessageProcessor: ======TOPIC===
这是我的错误,服务器正在控制台中显示数据。为了更好地理解,我修改了订阅者记录器以区分来自发布者的数据。
<logger message="==Subscriber=#[message.payload]====" level="INFO" doc:name="Logger"/>
现在控制台显示:
==Subscriber====TOPIC=======