Transformation result gets lost in a router chaining an async-reply service to a one-way service

• User impact:

  Medium
• Configuration:

  Hide

  <?xml version="1.0" encoding="UTF-8"?>
  <mule xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:vm="http://www.mulesoft.org/schema/mule/vm" xmlns:script="http://www.mulesoft.org/schema/mule/scripting"
  xsi:schemaLocation="
  http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/3.0/mule.xsd
  http://www.mulesoft.org/schema/mule/vm http://www.mulesoft.org/schema/mule/vm/3.0/mule-vm.xsd
  http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/3.0/mule-scripting.xsd
  ">

  <script:transformer name="appendBar">
  <script:script engine="groovy">
  <script:text>payload.collect() { it + '.bar' }</script:text>
  </script:script>
  </script:transformer>

  <model>
  <service name="Chain">
  <inbound>
  <vm:inbound-endpoint path="chain" />
  </inbound>
  <outbound>
  <chaining-router>
  <vm:outbound-endpoint path="async-reply" exchange-pattern="request-response" />
  <vm:outbound-endpoint path="logger" transformer-refs="appendBar" />
  </chaining-router>
  </outbound>
  </service>

  <service name="AsyncReply">
  <inbound>
  <vm:inbound-endpoint path="async-reply" exchange-pattern="request-response" />
  </inbound>
  <outbound>
  <list-message-splitter-router>
  <vm:outbound-endpoint path="foo-appender" exchange-pattern="request-response"/>
  <reply-to address="vm://async-reply.reply" />
  </list-message-splitter-router>
  </outbound>
  <async-reply timeout="0">
  <vm:inbound-endpoint path="async-reply.reply" />
  <collection-async-reply-router />
  </async-reply>
  </service>

  <service name="FooAppender">
  <inbound>
  <vm:inbound-endpoint path="foo-appender" exchange-pattern="request-response" />
  </inbound>
  <script:component>
  <script:script engine="groovy">
  <script:text>payload + '.foo'</script:text>
  </script:script>
  </script:component>
  </service>

  <service name="Logger">
  <inbound>
  <vm:inbound-endpoint path="logger" />
  </inbound>
  <!-- Can't use log-component because of http://www.mulesoft.org/jira/browse/MULE-5095 -->
  <script:component>
  <script:script engine="groovy">
  <script:text>
  log.info(payload)
  </script:text>
  </script:script>
  </script:component>
  </service>

  </model>
  </mule>

  Show

  <?xml version="1.0" encoding="UTF-8"?> <mule xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:vm="http://www.mulesoft.org/schema/mule/vm" xmlns:script="http://www.mulesoft.org/schema/mule/scripting" xsi:schemaLocation=" http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/3.0/mule.xsd http://www.mulesoft.org/schema/mule/vm http://www.mulesoft.org/schema/mule/vm/3.0/mule-vm.xsd http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/3.0/mule-scripting.xsd "> <script:transformer name="appendBar"> <script:script engine="groovy"> <script:text>payload.collect() { it + '.bar' }</script:text> </script:script> </script:transformer> <model> <service name="Chain"> <inbound> <vm:inbound-endpoint path="chain" /> </inbound> <outbound> <chaining-router> <vm:outbound-endpoint path="async-reply" exchange-pattern="request-response" /> <vm:outbound-endpoint path="logger" transformer-refs="appendBar" /> </chaining-router> </outbound> </service> <service name="AsyncReply"> <inbound> <vm:inbound-endpoint path="async-reply" exchange-pattern="request-response" /> </inbound> <outbound> <list-message-splitter-router> <vm:outbound-endpoint path="foo-appender" exchange-pattern="request-response"/> <reply-to address="vm://async-reply.reply" /> </list-message-splitter-router> </outbound> <async-reply timeout="0"> <vm:inbound-endpoint path="async-reply.reply" /> <collection-async-reply-router /> </async-reply> </service> <service name="FooAppender"> <inbound> <vm:inbound-endpoint path="foo-appender" exchange-pattern="request-response" /> </inbound> <script:component> <script:script engine="groovy"> <script:text>payload + '.foo'</script:text> </script:script> </script:component> </service> <service name="Logger"> <inbound> <vm:inbound-endpoint path="logger" /> </inbound> <!-- Can't use log-component because of http://www.mulesoft.org/jira/browse/MULE-5095 --> <script:component> <script:script engine="groovy"> <script:text> log.info(payload) </script:text> </script:script> </script:component> </service> </model> </mule>
• Similar Issues:

  None

In the attached configuration, the appendBar transformer defined on the outbound logger endpoint gets called, the message gets correctly transformed but when it hits the logger service, the payload is reverted to the value before transformation.

Test the attached config with: muleClient.dispatch("vm://chain", Arrays.asList("abc", "def"), null);

Getting logged: [abc.foo, def.foo]
Expected: [abc.foo.bar, def.foo.bar]