Posts

Showing posts with the label Mule Flow

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...

Recent Post

Recent Posts Widget