ddossot

  ...
  <http:outbound-endpoint address="http://foo.bar" />
  <logger level="INFO" message="#[string:#[context:serviceName] dispatched:#[message:correlationId]]" />
</flow>

ddossot

<flow name="tcp-client-cid">
  <tcp:inbound-endpoint host="localhost" port="15015" />
  <json:json-to-object-transformer />
  <script:component>
    <script:script engine="groovy">message.correlationId=payload.get('CID')</script:script>
  </script:component>
  <logger level="INFO" message="#[string:#[context:serviceName] received:#[message:correlationId]]" />
  ...
</flow>

ddossot

message.setJMSCorrelationID(UUID.randomUUID().toString());
producer.send(message);
LOG.info("jms-client sent:" + message.getJMSCorrelationID());

ddossot

<flow name="jms-client-cid">
  <jms:inbound-endpoint queue="jms-client-cid" />
  <logger level="INFO" message="#[string:#[context:serviceName] received:#[message:correlationId]]" />
  ...
</flow>

ddossot

<flow name="http-client-cid">
  <http:inbound-endpoint host="localhost" port="8989" path="client-cid" />
  <script:component>
    <script:script engine="groovy">message.correlationId=message.getInboundProperty('X-CID')</script:script>
  </script:component>
  <logger level="INFO" message="#[string:#[context:serviceName] received:#[message:correlationId]]" />
...
</flow>

ddossot

15:29:14,267 INFO  [org.mule.api.processor.LoggerMessageProcessor] http-server-cid received:421cb368-066b-11e1-9647-c5be7398b24e

ddossot

<flow name="http-server-cid">
  <http:inbound-endpoint host="localhost" port="8989" path="server-cid" />
  <script:component>
    <script:script engine="groovy">message.correlationId=message.id</script:script>
  </script:component>
  <logger level="INFO" message="#[string:#[context:serviceName] received:#[message:correlationId]]" />
  ...
</flow>

ddossot

<flow name="doublemetaphone-agent">
    <jms:inbound-endpoint queue="services.doublemetaphone" />
    <expression-transformer>
        <return-argument evaluator="groovy"
                         expression="new org.apache.commons.codec.language.DoubleMetaphone().encode(payload)" />
    </expression-transformer>                              
</flow>

ddossot

<bridge name="dynamic-agent-service"
        inboundAddress="http://localhost:8080/services"
        transformer-refs="object-to-string-transformer outbound-properties-remover"
        outboundAddress="jms://#[groovy:message.getInboundProperty('http.request.path').substring(1).replace('/','.')]"
        exchange-pattern="request-response" />

ddossot

<bridge name="single-agent-service"
        inboundAddress="http://localhost:8080/capitalizer"
        transformer-refs="object-to-string-transformer outbound-properties-remover"
        outboundAddress="jms://services.capitalizer"
        exchange-pattern="request-response" />

<flow name="capitalizer-agent">
    <jms:inbound-endpoint queue="services.capitalizer" />
    <expression-transformer>
        <return-argument evaluator="groovy"