WSO2 aggregator - xpath cannt traverse

Question

У меня есть эта служба прокси для агрегирования двух xml-сообщений в один.

1. Я настроил мой класс агрегатор с XPath
2. Я не уверен, работает ли мой XPath с пространством имен. Я не мог отслеживать журналы.

Моя конфигурация прокси:

<?xml version="1.0" encoding="UTF-8"?> 
<proxy xmlns="http://ws.apache.org/ns/synapse" 
     name="prescription" 
     transports="https http jms" 
     startOnLoad="true" 
     trace="disable"> 
    <description/> 
    <target> 
     <inSequence> 
     <aggregate> 
      <completeCondition> 
       <messageCount min="2" max="2"/> 
      </completeCondition> 
      <onComplete expression="//soapenv:Envelope//f:Prescription//f:identifier//f:id//@value"> 

       <send> 
        <endpoint> 
        <address uri="jms:/report?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&amp;java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;java.naming.provider.url=tcp://localhost:61616"/> 
        </endpoint> 
       </send> 

      </onComplete> 
     </aggregate> 

     </inSequence> 
     <outSequence> 
     <drop/> 
     </outSequence> 
     <faultSequence/> 
    </target> 
    <parameter name="transport.jms.ContentType"> 
     <rules> 
     <jmsProperty>contentType</jmsProperty> 
     <default>application/xml</default> 
     </rules> 
    </parameter> 
</proxy> 

Мои входные сообщения выглядит следующим образом: (Я хочу, чтобы агрегировать на основе идентификатора пациента)

<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ws="http://isova.wipro.com/"> 


<Prescription xmlns="http://hl7.org/fhir"> 
    <identifier> 
    <id value="A0001"/> 
    </identifier> 
    <status value="active"/> 
    <patient> 
    <type value="Patient"/> 
    <url value="Bhavani"/> 
    </patient> 
    <prescriber> 
    <type value="Provider"/> 
    <url value="Dr.Mathews"/> 
    </prescriber> 
    <medicine> 
    <identification> 
     <text value="Zintac"/> 
    </identification> 
    </medicine> 
</Prescription></soapenv:Envelope> 

Любые предложения?

С уважением Гуру @gnanagurus

---

Я не мог помочь решить эту проблему. Это мой последний прокси WSO2.

Эти два сообщения существуют в очереди «Репрезентация».

Сообщение1:

<?xml version='1.0' encoding='UTF-8'?><soapenv:Envelope xmlns:soapenv="http://www.w3.org/2003/05/soap-envelope"><soapenv:Body><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ws="http://isova.wipro.com/"> 


<Prescription xmlns="http://hl7.org/fhir"> 
    <identifier> 
    <id value="A0001"/> 
    </identifier> 
    <status value="active"/> 
    <patient> 
    <type value="Patient"/> 
    <url value="Bhavani"/> 
    </patient> 
    <prescriber> 
    <type value="Provider"/> 
    <url value="Dr.Mathews"/> 
    </prescriber> 
    <medicine> 
    <identification> 
     <text value="Zintac"/> 
    </identification> 
    </medicine> 
</Prescription></soapenv:Envelope></soapenv:Body></soapenv:Envelope> 

Сообщение 2:

<?xml version='1.0' encoding='UTF-8'?><soapenv:Envelope xmlns:soapenv="http://www.w3.org/2003/05/soap-envelope"><soapenv:Body><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ws="http://isova.wipro.com/"> 


<Prescription xmlns="http://hl7.org/fhir"> 
    <identifier> 
    <id value="A0001"/> 
    </identifier> 
    <status value="active"/> 
    <patient> 
    <type value="Patient"/> 
    <url value="Bhavani"/> 
    </patient> 
    <prescriber> 
    <type value="Provider"/> 
    <url value="Dr.John"/> 
    </prescriber> 
    <medicine> 
    <identification> 
     <text value="tintac"/> 
    </identification> 
    </medicine> 
</Prescription></soapenv:Envelope></soapenv:Body></soapenv:Envelope> 

Proxy:

<?xml version="1.0" encoding="UTF-8"?> 
<proxy xmlns="http://ws.apache.org/ns/synapse" 
     name="prescription" 
     transports="https http jms" 
     startOnLoad="true" 
     trace="disable"> 
    <description/> 
    <target> 
     <inSequence> 


     <aggregate> 
       <completeCondition> 
        <messageCount min="2"/> 
       </completeCondition> 
       <onComplete expression="/Prescription"> 
       <send> 
        <endpoint> 
        <address uri="jms:/report?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&amp;java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&amp;java.naming.provider.url=tcp://localhost:61616"/> 
        </endpoint> 
       </send> 
       </onComplete> 
      </aggregate> 
     </inSequence> 
     <outSequence> 
     <drop/> 
     </outSequence> 
     <faultSequence/> 
    </target> 
    <parameter name="transport.jms.ContentType"> 
     <rules> 
     <jmsProperty>contentType</jmsProperty> 
     <default>application/xml</default> 
     </rules> 
    </parameter> 
</proxy> 

Это не мое решение агрегации. Эти два сообщения не получают агрегатор. Я пробовал с несколькими xpath с пространствами имен. Anyhelp очень нужен.

Существует ли какой-либо Java-класс WSG2 Aggregator, который я могу использовать вместо агрегирующего агента?

С уважением Гуру

Answer 1

Ваш XPATH является ошибочным, так как вы не определение ваших имен.

Я считаю, что вы имеете дело с сообщениями SOAP. Если бы вы скопировали точное сообщение выше. Я не вижу тело SOAP? То, что вы должны делать, - обогатить полезную нагрузку xml в теле SOAP и активировать их из посредника aggrgate. Там вам нужно только указать XPATH, рассматривая тело SOAP как корень. В вашем случае это должно быть

<onComplete xmlns:f="http://hl7.org/fhir" expression="//f:Prescription/f:identifier/f:id/text()"> 

Answer 2

Да, вам необходимо определить пространство имен f. Вы можете сделать это непосредственно в самом начале:

<proxy xmlns="http://ws.apache.org/ns/synapse" xmlns:f="http://hl7.org/fhir" 

Тогда вы, конечно, можете сделать выходы журнала, чтобы проверить свои XPATH выражения (очень полезно):

<log level="custom"> 
    <property name="yourXPathTest" expression="$body/f:Prescription/f:identifier/f:id/@value"/> 
</log> 

Answer 3

То, что вы делаете, не является логически правильным. Вы не можете агрегировать сообщения в inSequence без использования медиатора итерации, помещенного в inSequence. Существует корреляция между медиатором Clone/Iterate и Aggregate. Вы можете собирать только сообщения, которые разбиваются или клонируются в пределах одной и той же службы прокси.