Я хочу реализовать поведение потребителя, используя Mule, ActiveMQ, который может читать сообщения JMS .... есть третья сторона/тема третьей стороны. нужно подписаться на них и начать слушать. Как я могу достичь этого в муле?прочитанное сообщение из очереди/темы в mule
Для получения рабочего разъема следуйте инструкциям в разделе this blog post. Если вы используете JMS1.1, вам даже не нужно указывать очередь или тему, они будут вести себя одинаково. Если вы используете 1.0b, убедитесь, что вы указали правильный тип.
Затем, вместо того, чтобы использовать исходящую конечную точку использовать входящую конечную точку:
<jms:inbound-endpoint topic="myTopic" connector-ref="Active_MQ" />
я, тем не менее, рекомендую использовать Anypoint Studio, что обеспечит вам очень простой интерфейс для такого рода конфигурации.
Чтобы прочитать сообщение из очереди 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>
Каким будет сообщение.inboundProperties ['JMSMessageID']? – NewJavaBee
JMSMessageID - это значение String, которое однозначно идентифицирует сообщение в очереди или теме. В этом примере используются транзакции, это может не иметь отношения к вашему запросу. –
Вы можете использовать простой поток, например:
Привет Victor .... спасибо за ответ ... Я видел, что блог, но в этом блоге его единственная очередь добавления и публикация сообщения в эту очередь ... Я не видел той части, где ее потребляют. – NewJavaBee
Тогда я отредактирую ответ. –
Как мы можем распечатать сообщение или проверить, прослушивает ли он эту очередь? Потому что, когда я иду в «view cosnumers», ничего нет. – NewJavaBee