0

我正在使用 mule 3.2.0 并在 java-class 中调用 muleclient.send 方法，该方法将soap-request发送到mule流（此处不存在），将其发送到接收请求的http端点，将其记录到我的数据库具有代理模式并将其传播到具有 Dispatcher 转换器的“ServiceFlow” - java 类，该类使用 MuleClient.send(String url, Object payload, Map messageProperties) 方法的调用将有效负载数组的一个对象分派到端点。然后它由 cxf:jax-ws-client 处理，再次登录到数据库并传输到 Dispatcher 的另一个实例（其中传入的有效负载再次是 Object[] 类型）。那里有执行服务调用的 http 端点。这部分工作正常。但是在收到响应时出现了麻烦。我已经把 Test1(2,3, 4）在我的流程中打印调用链的转换器（他们只是执行 System.out.println()），并看到它们以奇怪的顺序被调用：我有它像 1,3 然后是 TestTransformer（这也是sysouter）然后我在主流程“服务流程”的调用者中收到错误“NullPayload”，然后我收到测试 4 和测试 2 输出。模式“1Proxy”中的 responseTransformer-refs 将被忽略，就像在“ServiceProxy”中一样。我一直在寻找一个星期的解决方案，但找不到。在调试中，我可以看到名为“TestTransformer”的转换器具有预期的有效负载（Object []），但是当我在类调用者中收到它时，它显示为“NullPayload”。我现在可以看到我的一个端点具有路径元素而不是 ref，不确定这是否会对流量造成任何影响，但会检查它。还尝试使用“响应”块来确保我的流程按预期运行。任何建议表示赞赏。谢谢

这是我的配置的样子：

<http:endpoint  name="httpService"  address="${service.soap}" exchange-pattern="request-response" responseTimeout="${timeout}" />
<vm:endpoint  name="vmService"  path="vmService" exchange-pattern="request-response"/>

<pattern:web-service-proxy 
    name="ServiceProxy" 
    inboundEndpoint-ref="httpService" 
    transformer-refs="to-string logging" 
    responseTransformer-refs="to-string logging"
    outboundEndpoint-ref="vmService" />

<flow name="ServiceFlow" >
    <inbound-endpoint ref="vmService"/>
    <cxf:jaxws-service serviceClass="pkg.ServiceImpl" wsdlLocation="${service.wsdl}" enableMuleSoapHeaders="false" validationEnabled="true"/>
  <custom-transformer class="pkg.Dispatcher">
     <spring:property name="vmFlowPath" value="vm.logService"/>
  </custom-transformer>
  <custom-transformer name="TestTransformer" class="pkg.TestTransformer"/>
</flow>

<vm:endpoint  name="vm1In"  path="vm1In" exchange-pattern="request-response"/>
<vm:endpoint  name="vm1Out"  path="vm1Out" exchange-pattern="request-response"/>

<custom-transformer name="arrayGenerator" class="pkg.ArrayGenerator"/>
<custom-transformer name="objectExtractor" class="pkg.ObjectExtractor"/>
<custom-transformer name="faultChecker" class="pkg.FaultChecker"/>  
<custom-transformer name="objectLogging" class="pkg.ObjectLogger">

<pattern:web-service-proxy 
    name="1Proxy" 
    inboundEndpoint-ref="vm1In" 
    transformer-refs="arrayGenerator objectLogging" 
    responseTransformer-refs="objectLogging objectExtractor faultChecker"
    outboundEndpoint-ref="vm1Out" />

<flow name="logService">

<vm:inbound-endpoint path="vm.logService exchange-pattern="request-response"/>

<custom-transformer class="Test1"/>

<vm:outbound-endpoint ref="vm1In">
    <cxf:jaxws-client 
        serviceClass="pkg.ServiceImpl" 
        operation="import"
        enableMuleSoapHeaders="false"/>
    <object-to-string-transformer/>

</vm:outbound-endpoint>
<object-to-xml-transformer> 

<xm:xml-to-object-transformer returnClass="pkg.WSResponseClass"/>

<custom-transformer class="Test2"/>
</flow>

<flow name="DispatcherToServiceFlow">
    <custom-transformer class="Test3"/>
    <vm:inbound-endpoint path="vm1.Out"/>

    <custom-transformer class="pkg.Dispatcher">
        <spring:property name="vmFlowPath" value="vm.import"/>
    </custom-transformer>

</flow> 

<flow name="import">
    <vm:inbound-endpoint path="vm.import" exchange-pattern="request-response"/>

    <http:outbound-endpoint address="${importService}" responseTimeout="${timeout}" exchange-pattern="request-response" />

    <object-to-string-transformer/>
<custom-transformer class="Test4"/>
</flow>
4

1 回答 1

1

好吧，我的问题确实是“路径”元素，而不是使用“ref”元素来引用现有的 vm 端点，例如

<inbound-endpoint ref="vm1Out"/>
于 2012-12-15T07:52:05.850 回答