骡子消费JMS主题消息答案

【问题标题】：Mule consuming JMS topic message骡子消费JMS主题消息
【发布时间】：2015-05-16 00:23:37
【问题描述】：

我的流程是：

 <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，我在 anypoint 工作室控制台中没有立即收到响应。当我转到 AcitveMQ 控制台http://localhost:8161/admin/topics.jsp 并选择 sfdc 主题时，发送按钮将在 Anypoint Studio 控制台中获得响应。为什么我发布主题时不显示立即响应/订阅？

编辑

全局元素：

<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===

【问题讨论】：

可以添加你的jsm连接器配置的代码吗？
activemqFlow3有报错吗？你得到什么 HTTP 响应？
@DavidDossot，添加控制台日志

标签： mule

【解决方案1】：

这是我的错误，服务器在控制台中显示数据。为了更好地理解，我修改了订阅者记录器以区分来自发布者的数据。

<logger message="==Subscriber=#[message.payload]====" level="INFO" doc:name="Logger"/>

现在控制台显示：

 ==Subscriber====TOPIC=======

【讨论】：

什么服务器？ ActiveMQ 还是 Mule？
@DavidDossot，上面的更新答案:)。服务器没有问题