Skip to content

Instantly share code, notes, and snippets.

@ryan-omni3
ryan-omni3 / DestinationSystemA.xml
Last active April 30, 2019 21:31
Reliable Message Delivery for Multiple Systems in Mulesoft Anypoint
<flow name="DestinationSystemAFlow" doc:id="e85fc224-da20-4a8f-b4eb-9a5281f6e0c3" >
<jms:listener doc:name="Listener" doc:id="94da9f0f-4e6a-43c5-aedf-f962f2faca3e" config-ref="JMS_Config" destination="system_a" transactionalAction="ALWAYS_BEGIN">
<jms:consumer-type >
<jms:queue-consumer />
</jms:consumer-type>
</jms:listener>
<http:request method="GET" doc:name="System A" doc:id="ef9aad60-00c8-4524-8b14-f4cf86045aa5" config-ref="HTTPSystemA" path="/update"/>
</flow>
@ryan-omni3
ryan-omni3 / unreliabledelivery.xml
Created April 30, 2019 21:35
Reliable Message Delivery for Multiple Systems in Mulesoft Anypoint
<mule 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:request-config name="HTTP_Request_configuration" doc:name="HTTP Request configuration" doc:id="8cd01274-b235-4173-bb7c-6479ed111b62" />
<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="ae828bbb-d97c-4b03-9f68-61300b459655" >
<http:listener-connection host="0.0.0.0" port="8081" />
</http:listener-config>
<http:request-config name="HTTPSystemA" doc:name="HTTP Request configuration" doc:id="510d50eb-bfdf-4bcd-858d-43a6cc9c8e97" >
<http:request-connection host="systema" port="8081" />
@ryan-omni3
ryan-omni3 / reliable_delivery_with_jms_inline.xml
Created April 30, 2019 21:36
Reliable Message Delivery for Multiple Systems in Mulesoft Anypoint
<jms:config name="JMS_Config" doc:name="JMS Config" doc:id="07bb9d7a-eec8-42d4-b64b-616b27c9b582" >
<jms:active-mq-connection />
</jms:config>
<flow name="reliableDeliveryWithJMSFlowWithoutScatterGather" doc:id="c768d1f5-91d1-4548-bca2-02601b71f6c4" >
<http:listener doc:name="Listener" doc:id="8a1d7b2c-0d70-4e20-9c37-8f083c4001ed" config-ref="HTTP_Listener_config" path="/update"/>
<choice doc:name="Choice" doc:id="e956868b-c802-4c4f-8c93-ee59a136c1bc">
<when expression="#[payload.status == 1]">
<jms:publish doc:name="System A" doc:id="6b419a15-932d-4e0a-b38b-8a9448884e28" config-ref="JMS_Config" destination="system_a" />
</when>
</choice>
@ryan-omni3
ryan-omni3 / reliable_delivery_with_jms_scatter_gather.xml
Created April 30, 2019 21:38
Reliable Message Delivery for Multiple Systems in Mulesoft Anypoint
<jms:config name="JMS_Config" doc:name="JMS Config" doc:id="07bb9d7a-eec8-42d4-b64b-616b27c9b582" >
<jms:active-mq-connection />
</jms:config>
<flow name="reliableDeliveryWithJMSFlowWithoutScatterGather" doc:id="c768d1f5-91d1-4548-bca2-02601b71f6c4" >
<http:listener doc:name="Listener" doc:id="8a1d7b2c-0d70-4e20-9c37-8f083c4001ed" config-ref="HTTP_Listener_config" path="/update"/>
<scatter-gather doc:name="Scatter-Gather" doc:id="433ff431-08dc-4968-a8ac-d169e218afd6" >
<route >
<choice doc:name="Choice" doc:id="e956868b-c802-4c4f-8c93-ee59a136c1bc">
<when expression="#[payload.status == 1]">
<jms:publish doc:name="System A" doc:id="6b419a15-932d-4e0a-b38b-8a9448884e28" config-ref="JMS_Config" destination="system_a" />