JMS Connector in Mule | Active MQ Integration with Mule
JMS Connector is used to send & receive messages to queues with the help of java message service(JMS) api.
firstly we need to start Active MQ by clicking on activemq.bat
flow of JMS connector :
JMS connector configuration :
connector configuration :
file connector configuration :
output file is located in out folder of src/main/resources
URL : http://localhost:8085/api/activemq
Method : GET
Input :
Output :
XML project code :
<?xml version="1.0" encoding="UTF-8"?> <mule xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:jms="http://www.mulesoft.org/schema/mule/jms" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 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/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd"> <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8085" doc:name="HTTP Listener Configuration" basePath="/api"/> <jms:activemq-connector name="Active_MQ" username="admin" password="admin" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ"/> <flow name="jmsdemoFlow"> <http:listener config-ref="HTTP_Listener_Configuration" path="/activemq" doc:name="HTTP"/> <object-to-string-transformer doc:name="Object to String"/> <jms:outbound-endpoint connector-ref="Active_MQ" doc:name="JMS" queue="queue1"/> <set-payload value="message published............" doc:name="Set Payload"/> </flow> <flow name="jmsdemoFlow1"> <jms:inbound-endpoint connector-ref="Active_MQ" doc:name="JMS" queue="queue1"/> <file:outbound-endpoint path="src/main/resources/out" responseTimeout="10000" doc:name="File"/> </flow> </mule>
No comments:
Post a Comment