Mule 4: JMS Publish & Subscribe with Transformation

About the JMS Connector:

The JMS connector enables the application to exchange messages using the JMS implementation of our own choice. Its main features include:

• Pub/Sub pattern support on any given destination.
• Listen/Reply pattern support on any given destination.
• Publish-Consume pattern support on any given destination, with a fixed or temporary reply Queue.
• Fully compliant with JMS 2.0, 1.1, and 1.0.2 specifications.

Mule 4 Example: Connecting To ActiveMQ Configuration:

<jms:config name="JMS_Config" doc:name="JMS Config" doc:id="bda7c128-ed6b-4fab-bdfc-0c63148fb16d" >
		<jms:active-mq-connection username="XXXXX" password="XXXXX" >
			<jms:factory-configuration brokerUrl="tcp://localhost:61616" />
		</jms:active-mq-connection>
	</jms:config>




Below are listed JMS Operations in Mule – 4:

Use Case:

Publishing the source message into JMS-Queue and it will consume by an end system. In this scenario, I am publishing & consuming the JSON message from Queue, then converting it into XML format.

 

Mule Flow:

Step -1 :

Configure the HTTP Listener by giving hostname, port number, and path, along with this specify allowed methods (Optional) at the Advanced tab of HTTP connector.

Step-2:

Drag & Drop the Logger component to log the inbound message.

Step-3:

Configure publish operation of the JMS connector from the Mule palette window. And add connector-required libraries with connection details like the ones below.

And specify the Queue name to publish the message.

Step-4:

As in Step–3, configure the consume operation of the JMS connector from the Mule palette window.

And specify the consuming Queue name to read the message.

Step-5:

Drag & Drop the Transform Message component from the Mule palette window.

From the above screen, SampleData defines the root tag of XML message as a result.

Step-6:

Drag & Drop the Logger component to log the result XML message.

Final Mule Flow:

Final Config.xml:

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:salesforce="http://www.mulesoft.org/schema/mule/salesforce" xmlns:jms="http://www.mulesoft.org/schema/mule/jms"
	xmlns:ee="http://www.mulesoft.org/schema/mule/ee/core"
	xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/ee/core http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd
http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd
http://www.mulesoft.org/schema/mule/salesforce http://www.mulesoft.org/schema/mule/salesforce/current/mule-salesforce.xsd">
	<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="4862f344-02c0-4d4d-89f7-2572698011f2" >
		<http:listener-connection host="0.0.0.0" port="8084" />
	</http:listener-config>
		<jms:config name="JMS_Config" doc:name="JMS Config" doc:id="cbf14d84-19d6-4a3d-a288-dde77d6f2a75" >
		<jms:active-mq-connection username="admin" password="admin">
			<jms:caching-strategy >
				<jms:default-caching />
			</jms:caching-strategy>
			<jms:factory-configuration brokerUrl="tcp://localhost:61616" />
		</jms:active-mq-connection>
		<jms:consumer-config >
			<jms:consumer-type >
				<jms:queue-consumer />
			</jms:consumer-type>
		</jms:consumer-config>
	</jms:config>
	<flow name="MQ-PUB_SUB" doc:id="1cc1d138-1ead-4098-86ac-5f9cb6c74c96">
		<http:listener doc:name="Listener" doc:id="bbd9a567-6729-407f-b77a-71a33fd8bffb" config-ref="HTTP_Listener_config" path="mq" allowedMethods="POST">
		</http:listener>
		<logger level="INFO" doc:name="Logger" doc:id="e119c173-d4da-4c98-8823-a3a159286b5b" message="#[message.payload]"/>
		<jms:publish doc:name="Publish" doc:id="38c403b2-3b92-4924-86ee-e9efff43a8cb" config-ref="JMS_Config" destination="test"/>
		<jms:consume doc:name="Consume" doc:id="cbf84a03-9123-4ff1-ae2e-fd98f265c7cb" config-ref="JMS_Config" destination="test">
		</jms:consume>
		<ee:transform doc:name="Transform Message" doc:id="0dbd6d88-8254-452e-a308-7516b677449e">
			<ee:message>
				<ee:set-payload><![CDATA[%dw 2.0
output application/xml
---
SampleData : payload]]></ee:set-payload>
			</ee:message>
		</ee:transform>
		<logger level="INFO" doc:name="Logger" doc:id="590d01e3-122d-42db-89b4-3845dd45eb3a" message="XML Data -----> #[message.payload]"/>
	</flow>
	
</mule>

Input & Output: