JMS 메시지를 읽을 수있는 Mule, ActiveMQ를 사용하여 소비자 종류의 동작을 구현하고 싶습니다 .... 제 3 자 큐/토픽이 있습니다. 그들을 구독하고 청취를 시작해야합니다. 노새에서 어떻게 그걸 성취 할 수 있니?큐에서 메시지를 읽으십시오/뮬에있는 주제
답변
this blog post의 지침에 따라 작동중인 커넥터를 얻으십시오. JMS1.1을 사용하는 경우 대기열 또는 주제를 지정하지 않아도 동일하게 작동합니다. 1.0b를 사용하는 경우 올바른 유형을 지정하십시오. 내가 할, 그러나, Anypoint Studio을 사용하는 것이 좋습니다
<jms:inbound-endpoint topic="myTopic" connector-ref="Active_MQ" />
, 구성의 이런 종류의 당신에게 매우 간단한 인터페이스를 제공합니다 :
다음, 대신 아웃 바운드 엔드 포인트를 사용하는 인바운드 엔드 포인트를 사용합니다.
의 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>
message.inboundProperties [ 'JMSMessageID']는 무엇이 될까요? – NewJavaBee
JMSMessageID는 대기열 또는 주제의 메시지를 고유하게 식별하는 String 값입니다. 이 예에서는 트랜잭션이 사용되며 사용자의 요청과 관련이 없을 수 있습니다. –
"connector-ref ="Active_MQ "doc : name ="JMS "/>에있는
- 1. 하는 클라이언트가 큐에서 메시지를 수신
- 2. 주제 메시지를 activemq에 영구화 할 수 있습니까?
- 3. ActiveMQ 큐에서 모든 메시지를 큐에서 제거하지 않는 소비자 서비스
- 4. NServiceBus pub 큐에서 sub 큐로 메시지를 전송합니다.
- 5. MSMQIntegrationBinding이있는 WCF가 큐에서 메시지를 가져 오지 않습니다.
- 6. WCF MsmqIntegrationBinding - 큐에서 메시지를 선택하지 않음
- 7. Camel을 사용하여 큐에서 메시지를 투명하게 기록합니다.
- 8. ActiveMQ : 오래된 메시지를 큐에서 제거하는 방법?
- 9. Glassfish (v3) JMS 큐에서 메시지를 수신하는 방법
- 10. SpringIntegration은 처리하지 않고 큐에서 메시지를 제거합니다.
- 11. RabbitMQ 큐에서 메시지를 유지하는 TTL 최대 ms
- 12. JMS 메시지를 큐에서 제거하는 독립형 Java
- 13. AMQP (RabbitMQ) 큐에서 메시지를 삭제하는 방법은 무엇입니까?
- 14. 큐에서 한 번만 메시지를 읽는 방법
- 15. 여러 작업자가 RabbitMQ 큐에서 동일한 메시지를 사용합니다.
- 16. 조건부로 여러 소비자가 메시지를 처리하고 MSMQ 큐에서 메시지를 제거합니다.
- 17. MQTT 주제 및 메시지를 배열에 배치하십시오.
- 18. JMS : DLQ의 메시지를 주제 구독자에게 어떻게 재전송합니까?
- 19. JMS에서 메시지를 소비하는 동안 지연 발생 주제
- 20. 메시지가 큐에서 삭제되었습니다.
- 21. 큐에서 MSMQ 메시지 편집
- 22. , 주제
- 23. Bunny gem으로 큐에서 메시지를 처리하는 동안 정상 종료되었습니다.
- 24. MQException MQ 큐에서 메시지를 가져올 때 2046 오류가 발생합니다.
- 25. 된 javax.jms.JMSException : MQJMS2002은 : MQ 큐에서 메시지를 가져 오지 못했습니다
- 26. 특정 ServiceInsight를 사용하여 데드 레터 큐에서 메시지를 다시 보내려면 어떻게합니까?
- 27. Azure ServiceBus 큐에서 메시지를 수신하는 전제 NServicebus 응용 프로그램에서
- 28. 어떻게 여러 큐에서 임의로 메시지를 가져올 수 있습니까?
- 29. 예약 된 시간에 RabbitMQ에서 메시지를 큐에서 꺼내는 방법
- 30. C# 코드의 ActiveMQ 큐에서 메시지를 삭제할 수 있습니까?
안녕 빅터 .... 답장을 보내 주셔서 감사합니다 ... 나는 블로그를 보았다하지만 블로그 그것의 대기열을 추가하고 그 대기열에 메시지를 게시하는 것 ... 나는 소비하는 부분을 보지 못했습니다. – NewJavaBee
그 답을 편집합니다. –
어떻게 메시지를 인쇄 할 수 있습니까? 왜냐하면 내가 "뷰 Cosnumers"에 갈 때 아무것도 없다. – NewJavaBee