騾子消費JMS主題消息

我的流程是：騾子消費JMS主題消息

<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控制檯顯示在主題部分一位消費者，但我不接受在anypoint工作室控制檯立即作出反應，一旦擊中http://localhost:9001/producetopic網址。當我進入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===

來源

2015-05-15 bekur

您可以將您的JSM連接器配置的代碼？ – ericbn

'activemqFlow3'報告的任何錯誤？你會得到什麼HTTP響應？ –

@DavidDossot，添加控制檯日誌 – bekur

這是我的錯誤，服務器已在控制檯中顯示的數據。爲了更好地理解，我修改了用戶記錄器以區分出版商的數據。

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

現在控制檯顯示：

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

來源

2015-05-15 15:59:08 bekur

什麼服務器？ ActiveMQ還是Mule？ –

@DavidDossot，更新了上面的答案:)。在服務器上沒有錯 – bekur

騾子消費JMS主題消息

回答

相關問題