0

我正在使用迭代调解器和聚合调解器。我的要求是：

<p:GetPersonDataOperation xmlns:p="http://tempuri.org">
  <!--1 or more occurrences-->
  <xs:ID xmlns:xs="http://tempuri.org">1</xs:ID>
 </p:GetPersonDataOperation>

响应是：

<GetPersonDataCollection xmlns="http://tempuri.org">
 <GetPersonData>
  <AppInstanceID>1</AppInstanceID>
  <RecordID>349</RecordID>
  <ID>1</ID>
  <Name>name</Name>
  <LastName>lastname</LastName>
  <Descr>description</Descr>
  <Address>Park Street</Address>
 </GetPersonData>
</GetPersonDataCollection>

如果我不使用聚合调解器，那么我会得到上述响应，但是如果我使用聚合调解器，我会得到请求超时异常

我的顺序是：

<sequence xmlns="http://ws.apache.org/ns/synapse" name="GetPersonDataOperationSeq">
   <iterate xmlns:xs="http://tempuri.org" xmlns:ns="http://org.apache.synapse/xsd" xmlns:p="http://tempuri.org" preservePayload="true" attachPath="//p:GetPersonData" expression="//p:GetPersonData/xs:ID" id="Iterator1">
      <target>
         <sequence>
            <property name="ID" expression="//xs:ID" scope="default" type="STRING"/>
            <payloadFactory>
               <format>
                  <p:GetPersonData>
                     <xs:ID>$1</xs:ID>
                  </p:GetPersonData>
               </format>
               <args>
                  <arg expression="get-property('ID')"/>
               </args>
            </payloadFactory>
            <send receive="AggregatorSeq">
               <endpoint key="GetPersonDataEP"/>
            </send>
         </sequence>
      </target>
   </iterate>
</sequence>

从上面的序列中，我重定向到另一个名为 AggregatorSeq 的序列，我的 AggregatorSeq 是：

<sequence xmlns="http://ws.apache.org/ns/synapse" name="AggregatorSeq">
   <log level="custom">
      <property name="CamHereProp" value="*******************Yes??????????????**********************************************"/>
   </log>
   <aggregate>
      <completeCondition>
         <messageCount min="-1" max="-1"/>
      </completeCondition>
      <onComplete xmlns:ns="http://org.apache.synapse/xsd" xmlns:p="http://tempuri.org" expression="//p:GetPersonDataCollection">
         <send/>
      </onComplete>
   </aggregate>
</sequence>

我在做什么错。期待您的回答。在此先感谢

4

2 回答 2

0

尝试将迭代器的 ID 添加到聚合器。在你的情况下，它应该是，

<aggregate id="Iterator1">

此外，如果您的每个响应正文都以开头， <GetPersonData>那么您需要将其添加到 onComplete 中的表达式中。

<onComplete xmlns:ns="http://org.apache.synapse/xsd" xmlns:p="http://tempuri.org" expression="//p:GetPersonData">
于 2013-07-15T07:40:02.373 回答
-1

你能用你给出的代码指定问题吗？您可以使用<log level="full"/>调试，直到您的配置被执行到什么级别。

于 2013-07-14T05:50:42.780 回答