Mule ESB: невозможно скопировать сообщение с полезной нагрузкой потока - PullRequest
Новая
       20

Mule ESB: невозможно скопировать сообщение с полезной нагрузкой потока

6 голосов
/ 18 февраля 2012

У меня есть приложение Mule, где я отправляю запрос нескольким веб-сервисам и собираю список полученных ответов. Идея состоит в том, чтобы получить первый ответ из списка, возвращая его из CustomJavaClass, где обрабатывается список: 

return responses.get(0);

Я могу связаться с WSDL, если я попытаюсь достичь его через браузер, возвращенный WSDL выглядит так, как будто должен выглядеть.Но я пытаюсь отправить сообщение через SoapUi и получаю следующее исключение: 

Exception stack is:
1. Cannot copy message with a stream payload. Payload type is "org.apache.commons.httpclient.ContentLengthInputStream". Message payload is of type: ContentLengthInputStream (org.mule.api.MessagingException)
  org.mule.routing.outbound.AbstractSequenceRouter:73 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html)
--------------------------------------------------------------------------------
Root Exception stack trace:
org.mule.api.MessagingException: Cannot copy message with a stream payload. Payload type is "org.apache.commons.httpclient.ContentLengthInputStream". Message payload is of type: ContentLengthInputStream
    at org.mule.routing.outbound.AbstractSequenceRouter.route(AbstractSequenceRouter.java:73)
    at org.mule.routing.outbound.AbstractOutboundRouter$1.doInTransaction(AbstractOutboundRouter.java:102)
    at org.mule.routing.outbound.AbstractOutboundRouter$1.doInTransaction(AbstractOutboundRouter.java:99)
    + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything)

SOAPUi Exception: 

Failed to route event via endpoint: org.mule.api.processor.MessageProcessors$LifecyleAwareMessageProcessorWrapper@ceb6dd. Message payload is of type: ContentLengthInputStream

мои текущие настройки: 

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:mulexml="http://www.mulesoft.org/schema/mule/xml" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" xmlns:core="http://www.mulesoft.org/schema/mule/core" xmlns:cxf="http://www.mulesoft.org/schema/mule/cxf" xmlns:tcp="http://www.mulesoft.org/schema/mule/tcp" xmlns:jms="http://www.mulesoft.org/schema/mule/jms" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="CE-3.2.1" xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/xml http://www.mulesoft.org/schema/mule/xml/current/mule-xml.xsd 
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd 
http://www.mulesoft.org/schema/mule/cxf http://www.mulesoft.org/schema/mule/cxf/current/mule-cxf.xsd 
http://www.mulesoft.org/schema/mule/tcp http://www.mulesoft.org/schema/mule/tcp/current/mule-tcp.xsd 
http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd ">
    <flow name="flows1Flow1" doc:name="flows1Flow1">
        <http:inbound-endpoint exchange-pattern="request-response" address="http://localhost:4433/miniwebservice" encoding="UTF-8" mimeType="text/xml" doc:name="HTTP"/>
        <logger level="INFO" category="ddo" doc:name="Logger"/>
        <all doc:name="All">
            <processor-chain>
                <message-properties-transformer encoding="UTF-8" mimeType="text/xml" doc:name="Message Properties">
                    <add-message-property key="http.method" value="#[header:INBOUND:http.method]"/>
                </message-properties-transformer>
                <http:outbound-endpoint exchange-pattern="request-response" address="http://localhost:4435/miniwebservice#[header:INBOUND:http.request]" encoding="UTF-8" mimeType="text/xml" doc:name="HTTP"/>
                <mulexml:xslt-transformer mimeType="text/xml" maxIdleTransformers="2" maxActiveTransformers="5" xsl-file="C:\Users\kiesa\Desktop\XSLReplace.xsl" doc:name="XSLT"/>
            </processor-chain>
            <processor-chain>
                <message-properties-transformer encoding="UTF-8" mimeType="text/xml" doc:name="Message Properties">
                    <add-message-property key="http.method" value="#[header:INBOUND:http.method]"/>
                </message-properties-transformer>
                <http:outbound-endpoint exchange-pattern="request-response" address="http://localhost:4434/miniwebservice#[header:INBOUND:http.request]" encoding="UTF-8" mimeType="text/xml" doc:name="HTTP"/>
                <mulexml:xslt-transformer mimeType="text/xml" maxIdleTransformers="2" maxActiveTransformers="5" xsl-file="C:\Users\kiesa\Desktop\XSLReplace2.xsl" doc:name="XSLT"/>
            </processor-chain>
        </all>
        <mulexml:xml-to-object-transformer doc:name="XML to Object"/>
        <component class="CustomJavaClass" doc:name="Java"/>
        <byte-array-to-string-transformer ignoreBadInput="true" encoding="UTF-8" mimeType="text/xml" doc:name="Byte Array to String"/>
    </flow>
</mule>

1 Ответ

9 голосов
/ 18 февраля 2012

Получение WSDL работает, потому что запрос GET не несет никакой полезной нагрузки. Но когда вы пытаетесь вызвать метод SOAP, полезной нагрузкой POST является InputStream, который, конечно, не может быть отправлен несколько раз.

Таким образом: сериализуйте поток ввода HTTP с: 

<object-to-byte-array-transformer />

сразу после http: inbound-endpoint.

...