2

JMS メッセージがキューに配信されると、Stream Closer に関連するログ ステートメントが表示されます。私には正しくないように見えます..なぜこのメッセージが表示されるのですか?

2013-04-22 19:08:29,385 [DEBUG] org.mule.transport.jms.activemq.ActiveMQJmsConnector  - Returning dispatcher for endpoint: jms://retry.queue = EeJmsMessageDispatcher{this=5c5801d7, endpoint=jms://retry.queue, disposed=false}
2013-04-22 19:08:29,433 [DEBUG] org.mule.util.DefaultStreamCloserService  - Unable to find an StreamCloser for the stream type: class java.lang.String, the stream: <?xml version="1.0" encoding="UTF-8"?> < ....... rest of the XML   ....... />  will not be closed.

「ストリーム: 閉じられません。」とはどういう意味ですか?

これを修正するにはどうすればよいですか?

====編集=====

エラーが発生しています。JMS メッセージには XML がペイロードとして含まれています。ミュールのバージョン: 3.3.2

これが私の流れです

<flow name="sendToHost">
    <jms:inbound-endpoint queue="host.queue" exchange-pattern="one-way" />
    <copy-properties propertyName="*" />     
    <file:outbound-endpoint path="/hostmessages" outputPattern="outgoing-xml-[function:dateStamp].log" />
    <set-variable variableName="hostXML" value="#[payload]" />
    <flow-ref name="webServiceCall" />
    <flow-ref name="inspectWSResponse" />
    <exception-strategy ref="retryExceptionStrategy" />
</flow>

<flow name="resendFailedMessages">
    <description>   
        "*/15 07-18 * * ?" run every 15 minutes from 7 am to 6 pm every day -->
    </description>
    <quartz:inbound-endpoint jobName="hostRedeliveryJob" cronExpression="0 0/1 * * * ?">
        <quartz:endpoint-polling-job>
            <quartz:job-endpoint ref="redeliverToHost" />
        </quartz:endpoint-polling-job>
    </quartz:inbound-endpoint>
    <set-variable variableName="hostXML" value="#[payload]" />
    <logger message="QUARTZ found message for host" level="INFO" />
    <flow-ref name="webServiceCall" />
    <flow-ref name="inspectWSResponse" />
    <exception-strategy ref="retryExceptionStrategy" />
</flow>

<choice-exception-strategy name="retryExceptionStrategy">
    <catch-exception-strategy when="#[exception.causedBy(java.io.IOException)]">
        <logger message="In retryExceptionStrategy IO exception strategy. " level="ERROR" />
        <logger message="retryExceptionStrategy exception is #[exception.causeException]" level="ERROR" />
        <set-property propertyName="exception" value="#[exception.summaryMessage]" />
        <set-payload value="#[hostXML]" />
        <logger message="retryExceptionStrategy payload is #[payload]" level="ERROR" />
        <jms:outbound-endpoint queue="retry.queue" />
    </catch-exception-strategy>
    <catch-exception-strategy>
        <logger message="Other error in sending result to host in retryExceptionStrategy flow." level="INFO" />
        <set-property propertyName="exception" value="#[exception.summaryMessage]" />
        <set-payload value="#[hostXML]" />
        <jms:outbound-endpoint queue="declined.queue" />
    </catch-exception-strategy>
</choice-exception-strategy> 

<sub-flow name="webServiceCall">
    <cxf:proxy-client payload="body" enableMuleSoapHeaders="false">
        <cxf:inInterceptors>
            <spring:bean class="org.apache.cxf.interceptor.LoggingInInterceptor" />
        </cxf:inInterceptors>
        <cxf:outInterceptors>
            <spring:bean class="org.apache.cxf.interceptor.LoggingOutInterceptor" />
        </cxf:outInterceptors>
    </cxf:proxy-client>

    <outbound-endpoint address="${host.ws.url}" mimeType="text/xml" connector-ref="http.connector" />
    <byte-array-to-string-transformer />
</sub-flow>

 <sub-flow name="inspectWSResponse">
    <choice>
        <when expression="#[xpath('//acord:TestResult/acord:TestCode/acord:Name/@tc').value == '1']">
            <logger message="Message Delivered Successfully to host" level="INFO" />
        </when>
        <otherwise>
            <set-payload value="#[hostXML]" />
            <jms:outbound-endpoint queue="declined.queue" />
        </otherwise>
    </choice>
</sub-flow>
4

1 に答える 1

3

レベルのログ エントリDEBUGは通常、安全に無視できます。

この特定のケースでは、Mule がStreamCloserServiceストリームではなく文字列であるメッセージのペイロードで を使用しているようです。

ソース コードを見ると、例外が処理され、Mule がストリーミング ペイロードが実際にストリーミングされているかどうかを最初に確認せずに強制的に閉じようとした場合にのみ、これが発生する可能性があるようです。DEBUGこれは良性であり、副作用を引き起こすことはないため、このステートメントを無視しても問題ありません。

于 2013-04-22T23:36:57.780 に答える