從隊列中讀取消息/主題在騾

我想要使用Mule，ActiveMQ可以讀取JMS消息實現消費者類行爲....有一些第三方隊列/主題。需要訂閱他們並開始收聽。我怎樣才能達到騾子？從隊列中讀取消息/主題在騾

2014-11-20 NewJavaBee

按照this blog post中的說明獲取工作連接器。如果您使用的是JMS1.1，那麼您甚至不需要指定隊列或主題，它們的行爲將相同。如果您使用1.0b，請確保您指定了正確的類型。

然後，而不是使用出站端點使用入站端點：

<jms:inbound-endpoint topic="myTopic" connector-ref="Active_MQ" />

我這樣做，但是，建議使用Anypoint Studio，這將爲您提供一個非常簡單的界面，這種配置。

來源

2014-11-20 19:22:19

嗨維克多....感謝您的回覆......我看到的博客，但該博客它唯一的添加隊列並將消息發佈到該隊列中......我沒有看到它消耗的部分。 – NewJavaBee 2014-11-20 19:37:10

然後我會編輯答案。 – 2014-11-20 20:09:48

我們如何打印消息或檢查它是否正在偵聽該隊列？因爲當我在「查看cosnumers」時沒有任何內容。 – NewJavaBee 2014-11-20 20:31:34

讀取來自ActiveMQ的隊列OT主題相關的消息，可以簡單地把你的流程，例如：

<flow name="insert-operation" doc:name="insert-operation" doc:description="">  
    <jms:inbound-endpoint connector-ref="Active_MQ" exchange-pattern="request-response" queue="insert-jms" doc:name="JMS"> 
     <idempotent-redelivery-policy idExpression="#[message.inboundProperties['JMSMessageID']]" /> 
     <xa-transaction action="ALWAYS_BEGIN" /> 
    </jms:inbound-endpoint> 
... 
</flow>

來源

2014-11-20 19:52:12

什麼是message.inboundProperties ['JMSMessageID']？ – NewJavaBee 2014-11-20 20:32:07

JMSMessageID是一個字符串值，用於唯一標識隊列或主題中的消息。在這個例子中，使用了交易，它可能與您的請求無關。 – 2014-11-20 20:49:30

您可以使用簡單的流程，例如： – 2014-11-20 20:55:56

從隊列中讀取消息/主題在騾

回答

相關問題