騾子的選擇表達式給出流關閉錯誤

Question

我有下面的騾流，將xml消息轉換爲平面格式，然後根據輸入xml文件的類型轉換爲ftp（使用選擇）。 但是，一旦我發出消息，它會給出例外。你們能幫我們找出問題嗎？

<flow name="AWOutboundFlow"> 
    <file:inbound-endpoint path="E:\MuleTemp\DBS\outbound\aw\in" responseTimeout="10000" doc:name="File"/> 
    <set-variable variableName="millis" value="#[System.currentTimeMillis()]" doc:name="Variable"/> 
    <logger message="#[flowVars['millis']]" level="INFO" doc:name="Logger"/> 
    <choice doc:name="Choice"> 
     <when expression="#[xpath3('/cw:UniversalShipment/cw:Shipment/cw:TransportMode/cw:Code') == 'AIR']"> 
      <logger message="#[flowVars['millis']]: Classified to AW" level="INFO" doc:name="Logger"/> 
      <mulexml:jaxb-xml-to-object-transformer returnClass="com.chasoft.schema.UniversalShipmentData" encoding="UTF-8" mimeType="text/xml" jaxbContext-ref="JAXB_Context" doc:name="XML to JAXB Object"/> 
      <transformer ref="AWShipmentOutbound" doc:name="Transformer Reference"/> 
      <ftp:outbound-endpoint binary="true" host="localhost" port="21" path="/outbound/aw/out" user="DBS" password="502011" responseTimeout="60000" doc:name="FTP" outputPattern="aw_out_#[flowVars['millis']].dat" encoding="UTF-8"> 
       <reconnect frequency="10000"/> 
      </ftp:outbound-endpoint> 
     </when> 
     <when expression="#[xpath3('/cw:UniversalShipment/cw:Shipment/cw:TransportMode/cw:Code') == 'SEA']"> 
      <logger message="#[flowVars['millis']]: Classified to BL" level="INFO" doc:name="Logger"/> 
      <mulexml:jaxb-xml-to-object-transformer returnClass="com.chasoft.schema.UniversalShipmentData" encoding="UTF-8" mimeType="text/xml" jaxbContext-ref="JAXB_Context" doc:name="XML to JAXB Object"/> 
      <transformer ref="BLShipmentOutbound" doc:name="Transformer Reference"/> 
      <ftp:outbound-endpoint binary="true" host="localhost" port="21" path="/outbound/bl/out" user="DBS" password="502011" responseTimeout="60000" doc:name="FTP" outputPattern="bl_out_#[flowVars['millis']].dat"/> 
     </when> 
     <when expression="#[xpath3('/cw:UniversalEvent/cw:Event/cw:EventTime') != '']"> 
      <logger message="#[flowVars['millis']]: Classified toEVENT" level="INFO" doc:name="Logger"/> 
      <mulexml:jaxb-xml-to-object-transformer jaxbContext-ref="JAXB_Context" doc:name="XML to JAXB Object" encoding="UTF-8" mimeType="text/xml" returnClass="com.chasoft.schema.UniversalEventData"/> 
      <transformer ref="EventOutbound" doc:name="Transformer Reference"/> 
      <ftp:outbound-endpoint binary="true" host="localhost" port="21" path="/outbound/event/out" user="DBS" password="502011" responseTimeout="60000" doc:name="FTP" outputPattern="event_out_#[flowVars['millis']].dat"/> 
     </when> 
     <otherwise> 
      <logger level="INFO" message="#[flowVars['millis']]: UNKNOWN Classification" doc:name="Logger"/> 
     </otherwise> 
    </choice> 
</flow> 

劃痕樣本輸入文件：

<UniversalShipment xmlns="http://www.cargowise.com/Schemas/Universal/2011/11" version="1.1"> 
    <Shipment> 
     ..... 
     <TransportMode> 
      <Code>AIR</Code> 
      <Description>Air Freight</Description> 
     </TransportMode> 

例外：

ERROR 2016-01-27 23:03:17,453 [[dbschenker].AWOutboundFlow.stage1.04] org.mule.exception.DefaultMessagingExceptionStrategy: Message : Execution of the expression "xpath3('/cw:UniversalShipment/cw:Shipment/cw:TransportMode/cw:Code') == 'SEA'" failed. (org.mule.api.expression.ExpressionRuntimeException). Message payload is of type: DeferredDocumentImpl Type : org.mule.api.MessagingException Code : MULE_ERROR--2 JavaDoc : http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html Payload : [#document: null]

Exception stack is: 1. Stream Closed (java.io.IOException) java.io.FileInputStream:-2 (null) 2. java.io.IOException: Stream Closed (org.mule.api.MuleRuntimeException) org.mule.module.xml.el.XPath3Function:151 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MuleRuntimeException.html) 3. [Error: java.io.IOException: Stream Closed] [Near : {... xpath3('/cw:UniversalShipment/ ....}] ^ [Line: 1, Column: 1] (org.mule.mvel2.CompileException) org.mule.mvel2.optimizers.impl.refl.ReflectiveAccessorOptimizer:438 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/mvel2/CompileException.html) 4. Execution of the expression "xpath3('/cw:UniversalShipment/cw:Shipment/cw:TransportMode/cw:Code') == 'SEA'" failed. (org.mule.api.expression.ExpressionRuntimeException) org.mule.el.mvel.MVELExpressionLanguage:232 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/expression/ExpressionRuntimeException.html) 5. Execution of the expression "xpath3('/cw:UniversalShipment/cw:Shipment/cw:TransportMode/cw:Code') == 'SEA'" failed. (org.mule.api.expression.ExpressionRuntimeException). Message payload is of type: DeferredDocumentImpl (org.mule.api.MessagingException) org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor:32 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html)

Answer 1

這裏是發生了什麼：

• 騾子拿起文件，並創建從InputStream它，
• 它評估的第一xpath3表達，或此，爲了讀取文件消耗流，
• 它試圖評估第二xpath3表達，因爲InputStream已被消耗在火熄滅，關閉，無法」不要再讀了。

解決方案：用<object-to-byte-array-transformer />因此它的內容可以在下游處理器連連讀取choice消息處理器之前反序列化在byte[]的InputStream。