gistfile1.xml

<service name="UserProvisioningService">
  <inbound>
    <http:inbound-endpoint address="http://localhost:8080/rmq/users" synchronous="true">
      <transformers>
        <object-to-string-transformer />
        <message-properties-transformer scope="session">
          <add-message-property key="userDetails"
                                value="#[groovy:org.json.simple.JSONValue.parse(payload)]" />
        </message-properties-transformer>
      </transformers>
      <response-transformers>
        <expression-transformer>
          <return-argument expression="org.json.simple.JSONValue.toJSONString(payload)"
                           evaluator="groovy"/>
        </expression-transformer>
      </response-transformers>
    </http:inbound-endpoint>
  </inbound>
  <outbound>
    <chaining-router>
      <erlang:outbound-endpoint node="rabbit@${host.name}"
                                moduleFunction="rabbit_access_control:add_user"
                                invocationType="RPC"
                                synchronous="true">
        <transformers>
          <expression-transformer>
            <return-argument expression="[userDetails.username.bytes,userDetails.password.bytes]"
                             evaluator="groovy" />
          </expression-transformer>
        </transformers>
      </erlang:outbound-endpoint>
      
      <vm:outbound-endpoint path="rabbitmq.permissions.set"
                            synchronous="true" />
    </chaining-router>
  </outbound>
</service>