WSO2 ESB агрегат с двумя респонами - PullRequest
Новая
       14

WSO2 ESB агрегат с двумя респонами

0 голосов
/ 29 августа 2018

У меня есть API для создания итераций и агрегирования. Но оба ответа не объединены. время от времени оба ответа показаны как одиночные. Я вызвал этот запрос как метод POST, а тег Info отправил как AD. секция inSequence работает. но тег outSequence оба ответа не объединены. Пожалуйста, помогите мне продолжить это. 

<?xml version="1.0" encoding="UTF-8"?>
<api context="/Info" name="InfoRequestAPI" xmlns="http://ws.apache.org/ns/synapse">
    <resource methods="POST" protocol="http">
        <inSequence>
            <property expression="$body//Request/OptionInfoRequest/Info" name="OptionInfo" scope="default" type="STRING"/>  

            <script language="js"><![CDATA[var payloadXML = mc.getPayloadXML();
                var xml = '<ItemList>';
                for each (var item in String(mc.getProperty("OptionInfo")).split(',')) {
                    xml +='<item>'+item+'</item>';
                }
                xml +='</ItemList>';
                payloadXML.appendChild(new XML(xml));
                mc.setPayloadXML(payloadXML);
                mc.setProperty("ORIGINAL_PAYLOAD",payloadXML);]]></script>
            <iterate continueParent="true" expression="$body//Request/ItemList/item" id="option_info_request" sequential="true" xmlns:fn="http://www.w3.org/2005/xpath-functions">
                <target>
                    <sequence>
                        <switch source="//item" xmlns:m0="$body">
                            <case regex="A">                                    
                                <send>
                                    <endpoint>
                                        <http format="rest" method="post" uri-template="http://localhost:8280/oneOption"/>
                                    </endpoint>
                                </send>
                            </case>
                            <case regex="D">                                    
                                <send>
                                    <endpoint>
                                        <http format="rest" method="post" uri-template="http://localhost:8280/secondOption"/>
                                    </endpoint>
                                </send>
                            </case>                                
                            <default>
                                <send>
                                    <endpoint key="error_response"/>
                                </send>
                            </default>
                        </switch>
                    </sequence>
                </target>
            </iterate>
        </inSequence>
        <outSequence>
            <property name="ECNCLOSING_ELEMENT" scope="default">
                <wrapper xmlns=""/>
            </property>               
            <aggregate id="option_info_request">
                <completeCondition timeout="10">
                    <messageCount max="-1" min="-1"/>
                </completeCondition>                        
                    <onComplete xmlns:ns="http://org.apache.synapse/xsd" expression="$body/*[1]" enclosingElementProperty="">                       
                    <send/>
                </onComplete>
            </aggregate>                
            <respond/>
        </outSequence>
        <faultSequence/>                
    </resource>
</api>

Ответы [ 2 ]

0 голосов
/ 09 ноября 2018

Я добавил, как следующий код. Это работает нормально для меня. 

            <property name="enclosing_element" scope="default">
                <Reply/>
            </property>


            <aggregate id="option_info_request">
                <completeCondition timeout="60">
                    <messageCount max="-1" min="-1"/>
                </completeCondition>
                <onComplete enclosingElementProperty="enclosing_element" expression="$env/*[local-name()='Body']/*">                        
                </onComplete>
            </aggregate>
0 голосов
/ 29 августа 2018

В совокупности почему enclosingElementProperty="" пусто, это свойство действует как корневой тег для всех повторяющихся результатов, вам нужно определить свойство и затем использовать его в enclosingElementProperty, что-то вроде этого 

<property name="ECNCLOSING_ELEMENT" scope="default">
    <wrapper xmlns=""/>
</property>

, а затем 

  <onComplete xmlns:ns="http://org.apache.synapse/xsd" expression="$body/*[1]" enclosingElementProperty="ECNCLOSING_ELEMENT">
...