Posts

Showing posts from December 18, 2017

Mule Configuration XML tags for RabbitMQ

Mule Configuration XML tags

As we know, AMQP Connector was not auto included in the Studio/ Eclipse. I have created mule xml configuration manually for one of my project. Before started writing flow and global variables in mule configurations file, we need to write correct mule tag for rabbitmq so that Flow can work without breaking.

Below is the tested mule tag.

<mule xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:db="http://www.mulesoft.org/schema/mule/db" xmlns:jdbc-ee="http://www.mulesoft.org/schema/mule/ee/jdbc" xmlns:metadata="http://www.mulesoft.org/schema/mule/metadata" xmlns:json="http://www.mulesoft.org/schema/mule/json" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:amqp="http://www.mulesoft.org/schema/mule/amqp" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.spri…

Mule Flow: Reading messages from rabbitmq

In a project, Our Mule service was reading some messages from Rabbit MQ in the project. After that these messages was transformed from byte-array to object in json format. Step 2 was to convert these JSON object into the Java bean object. After converting it to Java object, passed these java object messages into our main java component for business logic.

To achieving this, I followed below steps: Reading some messages from Rabbit MQ Transformed from byte-array to object in json format Convert these JSON object into the Java bean object Sent this workload into the Java class.

For Step 1: Created some global variables in the MULE configuration xml file.

<amqp:connector validateConnections="true" doc:name="AMQP Connector" name="AMQP_0_9_Connector" />

<amqp:endpoint exchangeName="main-exchange" queueName="<<Your Queue Name>>" exchangeDurable="true" name="AMQP_0_9_queue1" responseTimeout="10000" doc…

Recent Post

Recent Posts Widget