如何覆盖mule中的有效负载

Question

我有一个Soap请求进入骡子流.我的任务是从有效负载中获取信息,并根据结果将原始请求推送到不同的jms队列.

为了从有效负载中获取所需信息,我使用的是XSLT转换器(不是XPath,因为我需要从一个元素获取IDREF属性,基于IDREF,从IDREF对象中获取元素然后是一个子元素).

基于XSLT转换的结果,我使用choice元素来推送原始有效负载.我将原始有效负载存储在会话中(也可以在入站中执行).在XSLT转换后,应用选择路由器以找出适当的队列,然后将原始有效负载推入队列(存储在会话变量中的原始有效负载).我正在使用<expression-component>元素.下面是mule-flow的片段:

<flow name="ProcessXML121Order">
    <jms:inbound-endpoint queue="mviq.121.order" exchange-pattern="one-way" />
    <logger message="121 order payload is #[payload]" level="INFO" />
    <message-properties-transformer scope="session">
        <add-message-property key="mviPayload" value="#[payload]"/>
    </message-properties-transformer>
    <xm:xslt-transformer xsl-file="chooseVendor.xslt" />
    <logger message="After xsl file payload is #[payload]" level="INFO" />      
    <choice>
        <when expression="'EMSI'">
            <logger message="Vendor is EMSI" level="INFO" />
            <expression-component>payload=#[header:SESSION:mviPayload]</expression-component>
            <jms:outbound-endpoint queue="mviq.121.order.emsi" />
        </when>
        <when expression="'PRMD'">
            <logger message="Vendor is PRMD" level="INFO" />
            <jms:outbound-endpoint queue="mviq.121.order.prmd" />
        </when>
        <when expression="'RSA'">
            <logger message="Vendor is RSA" level="INFO" />
            <logger message="RSA payload is #[payload]" level="INFO" />
            <jms:outbound-endpoint queue="mviq.121.order.rsa" />
        </when>
        <otherwise>
            <logger message="Vendor is Error" level="INFO" />
            <logger message="Vendor error payload is #[payload]" level="INFO" />
            <jms:outbound-endpoint queue="mviq.error" />
        </otherwise>
    </choice>
</flow>

评估payload =#[header:SESSION:mviPayload]时抛出以下异常

[ProcessXML121Order.stage1.02] exception.AbstractExceptionListener (AbstractExceptionListener.java:296) - 
********************************************************************************
Message               : Execution of the expression "payload=#[header:SESSION:mviPayload]" failed. (org.mule.api.expression.ExpressionRuntimeException). Message payload is of type: byte[]
Code                  : MULE_ERROR-29999
--------------------------------------------------------------------------------
Exception stack is:
1. [Error: illegal use of operator: +]
[Near : {... Unknown ....}]
             ^
[Line: 1, Column: 0] (org.mvel2.CompileException)
  org.mvel2.ast.OperatorNode:46 (null)
2. Execution of the expression "payload=#[header:SESSION:mviPayload]" failed. (org.mule.api.expression.ExpressionRuntimeException)
  org.mule.el.mvel.MVELExpressionLanguage:211 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/expression/ExpressionRuntimeException.html)
3. Execution of the expression "payload=#[header:SESSION:mviPayload]" failed. (org.mule.api.expression.ExpressionRuntimeException). Message payload is of type: byte[] (org.mule.api.MessagingException)
  org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor:35 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html)
--------------------------------------------------------------------------------
Root Exception stack trace:
[Error: illegal use of operator: +]
[Near : {... Unknown ....}]
             ^
[Line: 1, Column: 0]
    at org.mvel2.ast.OperatorNode.getReducedValueAccelerated(OperatorNode.java:46)
    at org.mvel2.MVELRuntime.execute(MVELRuntime.java:85)
    at org.mvel2.compiler.CompiledExpression.getValue(CompiledExpression.java:105)
    + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything)
********************************************************************************

我有两个问题:

1. 如何覆盖原始有效负载？(不是说这是最好的方式)
2. 在这种情况下,更好的方法是什么？是否建议保持原始有效负载完好(在这种情况下)并将XSLT输出存储在其他变量中？我怎样才能做到这一点？我可以使用什么路径(骡子组件)来实现这一目标？我对Mule很新,并寻求社区建议.

感谢您抽出时间研究这个问题.

Answer 1

在回答你的问题之前,让我们重写这个破碎的表达:

<expression-component>payload=#[header:SESSION:mviPayload]</expression-component>

如:

<set-payload value="#[sessionVars.mviPayload]" />

以下内容也可行,但没有充分理由会更复杂:

<expression-component>payload=sessionVars.mviPayload</expression-component>

这个:

<message-properties-transformer scope="session">
    <add-message-property key="mviPayload" value="#[payload]"/>
</message-properties-transformer>

会写得更好:

<set-session-variable variableName="mviPayload" value="#[message.payload]" />

现在回答你的问题:

1. 使用 set-payload
2. 你正在做的是最好的:变换器,如XSL-T,自然地应用于当前的消息有效负载,因此将原始文件保存在属性中然后转换主有效负载是可以的.只有一件事:更喜欢流变量而不是会话变量.实际上,在您的情况下,我认为您不需要此流程之外的原始有效负载,因此在会话中存储是过度的.

所以我建议你使用:

<set-variable variableName="mviPayload" value="#[message.payload]" />

存储原始有效负载和以下内容以重新建立它:

<set-payload value="#[mviPayload]" />