Created
July 18, 2017 07:59
-
-
Save ricston-git/2056d73e70e55fe57c96f45dc65f328e to your computer and use it in GitHub Desktop.
Mule flow for connecting to RabbitMQ using the default Auto Acknowledgements.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<amqp:endpoint exchangeName="main-exchange" queueName="queue1" exchangeDurable="true" name="AMQP_0_9_queue1" responseTimeout="10000" doc:name="AMQP-0-9" routingKey="rk-q1" exchangeType="direct" exchange-pattern="request-response"/> | |
<amqp:endpoint exchangeName="main-exchange" queueName="queue2" name="AMQP_0_9_queue2" responseTimeout="10000" doc:name="AMQP-0-9" exchangeDurable="true" routingKey="rk-q2" exchangeType="direct"/> | |
<amqp:connector name="AMQP_0_9_Connector" validateConnections="true" username="administrator" password="password" doc:name="AMQP-0-9 Connector"/> | |
<flow name="rabbitmq-receiveFromServer-queuetestFlow"> | |
<amqp:inbound-endpoint responseTimeout="10000" exchange-pattern="request-response" doc:name="AMQP-MSG-FROM-QUEUE1" ref="AMQP_0_9_queue1" connector-ref="AMQP_0_9_Connector"/> | |
<byte-array-to-object-transformer returnClass="java.lang.String" doc:name="Byte Array to Object"/> | |
<logger message="Message from Queue1: #[payload]" level="INFO" doc:name="Logger: Incoming from RabbitMQ"/> | |
<set-payload value="#["hello"]" mimeType="text/plain" doc:name="Set Message you want to Send"/> | |
<amqp:outbound-endpoint responseTimeout="10000" exchange-pattern="request-response" ref="AMQP_0_9_queue2" doc:name="AMQP-MSG-TO-QUEUE2" connector-ref="AMQP_0_9_Connector"/> | |
</flow> | |
<flow name="rabbitmq-printMessageSentToServer-queuetestFlows"> | |
<amqp:inbound-endpoint responseTimeout="10000" exchange-pattern="request-response" doc:name="AMQP-MSG-FROM-QUEUE2" ref="AMQP_0_9_queue2" connector-ref="AMQP_0_9_Connector"/> | |
<byte-array-to-object-transformer returnClass="java.lang.String" doc:name="Byte Array to Object"/> | |
<logger message="Message from Queue2: #[payload]" level="INFO" doc:name="Logger: Outgoing to RabbitMQ"/> | |
</flow> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment