Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <jms:activemq-connector name="Active_MQ" username="....." password="..." brokerURL="...." validateConnections="true" doc:name="Active MQ" numberOfConsumers="1" maxRedelivery="-1" disableTemporaryReplyToDestinations="true" persistentDelivery="true"/>
- <flow name="testFlow">
- <jms:inbound-endpoint connector-ref="Active_MQ" doc:name="JMS" queue="InQ" exchange-pattern="request-response">
- <jms:client-ack-transaction action="ALWAYS_BEGIN"/>
- </jms:inbound-endpoint>
- <logger level="INFO" doc:name="Logger" message="**testCheck#[payload]"/>
- <choice doc:name="Choice">
- <when expression="#[message.inboundProperties.JMSXGroupId=='A']">
- <logger level="INFO" doc:name="Logger" message="***first***"/>
- <flow-ref name="ClientA" doc:name="ClientA"/>
- </when>
- <when expression="#[message.inboundProperties.JMSXGroupId=='B']">
- <flow-ref name="ClientB" doc:name="ClientB"/>
- </when>
- <when expression="#[message.inboundProperties.JMSXGroupId=='C']">
- <flow-ref name="ClientC" doc:name="ClientC"/>
- </when>
- <otherwise>
- <logger level="INFO" doc:name=" Other Logger"/>
- </otherwise>
- </choice>
- </flow>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement