从队列中读取消息/主题在骡

我想要使用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

从队列中读取消息/主题在骡

回答

相关问题