source: ccr/trunk/nhin-vista/projects/NHINC/Current/Product/Production/Adapters/General/AdapterBPEL/src/AdapterDocQuery.bpel@ 507

<?xml version="1.0" encoding="UTF-8"?>
<process
    name="AdapterDocQuery"
    targetNamespace="urn:gov:hhs:fha:nhinc:adapters:general:adapterbpel:adapterdocquery"
    xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
    xmlns:xsd="http://www.w3.org/2001/XMLSchema"
    xmlns:sxt="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Trace" 
    xmlns:sxed="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor"
    xmlns:sxeh="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/ErrorHandling"
    xmlns:tns="urn:gov:hhs:fha:nhinc:adapters:general:adapterbpel:adapterdocquery" 
    xmlns:query="urn:oasis:names:tc:ebxml-regrep:xsd:query:3.0" xmlns:ns0="urn:oasis:names:tc:ebxml-regrep:xsd:rs:3.0">
    <import namespace="urn:gov:hhs:fha:nhinc:adapterdocquery" location="Interfaces/wsdl/AdapterDocQuery.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
    <import namespace="http://enterprise.netbeans.org/bpel/AdapterComponentDocRegistryWrapper" location="AdapterComponentDocRegistryWrapper.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
    <import namespace="urn:ihe:iti:xds-b:2007" location="Interfaces/wsdl/AdapterComponentDocRegistry.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
    <partnerLinks>
        <partnerLink name="AdapterComponentDocQueryPL" xmlns:tns="http://enterprise.netbeans.org/bpel/AdapterComponentDocRegistryWrapper" partnerLinkType="tns:DocumentRegistry_LinkType" partnerRole="DocumentRegistry_Role"/>
        <partnerLink name="AdapterDocQueryPL" xmlns:tns="urn:gov:hhs:fha:nhinc:adapterdocquery" partnerLinkType="tns:AdapterDocQuery" myRole="AdapterDocQueryPortTypeRole"/>
    </partnerLinks>
    <variables>
        <variable name="RespondingGateway_CrossGatewayQueryIn" xmlns:tns="urn:gov:hhs:fha:nhinc:adapterdocquery" messageType="tns:RespondingGateway_CrossGatewayQueryRequestMessage"/>
        <variable name="RespondingGateway_CrossGatewayQueryOut" xmlns:tns="urn:gov:hhs:fha:nhinc:adapterdocquery" messageType="tns:RespondingGateway_CrossGatewayQueryResponseMessage"/>
        <variable name="DocumentRegistry_RegistryStoredQueryIn" xmlns:ihe="urn:ihe:iti:xds-b:2007" messageType="ihe:RegistryStoredQuery_Message"/>
        <variable name="DocumentRegistry_RegistryStoredQueryOut" xmlns:ihe="urn:ihe:iti:xds-b:2007" messageType="ihe:RegistryStoredQueryResponse_Message"/>
    </variables>
    <sequence>
        <receive name="ReceiveDocQuery" createInstance="yes" partnerLink="AdapterDocQueryPL" operation="RespondingGateway_CrossGatewayQuery" xmlns:tns="urn:gov:hhs:fha:nhinc:adapterdocquery" portType="tns:AdapterDocQueryPortType" variable="RespondingGateway_CrossGatewayQueryIn"/> 
        <scope name="AdapterDocQueryScope">
            <faultHandlers>
                <catch faultName="sxeh:systemFault" faultVariable="systemFaultVar" faultMessageType="sxeh:faultMessage">
                    <sequence name="Sequence1">
                        <assign name="AssignErrors">
                            <sxt:trace>
                                <sxt:log level="info" location="onStart">
                                    <from>'AdapterDocQuery.bpel - System fault encountered processing an AdhocQuery request. Fault details follow...'</from>
                                </sxt:log>
                                <sxt:log level="warning" location="onStart">
                                    <from variable="systemFaultVar"/>
                                </sxt:log>
                            </sxt:trace>
                            <copy>
                                <from>'urn:oasis:names:tc:ebxml-regrep:ResponseStatusType:Failure'</from>
                                    <to>$RespondingGateway_CrossGatewayQueryOut.RespondingGateway_CrossGatewayQueryResponse/@status</to>
                            </copy>
                                <copy>
                                <from>0</from>
                                    <to>$RespondingGateway_CrossGatewayQueryOut.RespondingGateway_CrossGatewayQueryResponse/@totalResultCount</to>
                            </copy>
                                <copy>
                                <from>'XDSRegistryError'</from>
                                    <to>$RespondingGateway_CrossGatewayQueryOut.RespondingGateway_CrossGatewayQueryResponse/ns0:RegistryErrorList/ns0:RegistryError/@errorCode</to>
                            </copy>
                                <copy>
                                <from>'Error'</from>
                                    <to>$RespondingGateway_CrossGatewayQueryOut.RespondingGateway_CrossGatewayQueryResponse/ns0:RegistryErrorList/ns0:RegistryError/@severity</to>
                            </copy>
                                <copy>
                                <from>'Error calling document registry'</from>
                                    <to>$RespondingGateway_CrossGatewayQueryOut.RespondingGateway_CrossGatewayQueryResponse/ns0:RegistryErrorList/ns0:RegistryError/@codeContext</to>
                            </copy>
                        </assign>
                        <reply name="ReplyFromFault" partnerLink="AdapterDocQueryPL" operation="RespondingGateway_CrossGatewayQuery" xmlns:tns="urn:gov:hhs:fha:nhinc:adapterdocquery" portType="tns:AdapterDocQueryPortType" variable="RespondingGateway_CrossGatewayQueryOut"/>
                        <exit name="ExitAfterFault"/>
                    </sequence>
                </catch>
            </faultHandlers>
            <sequence name="AdapterDocQuerySeq">
                <assign name="AssignRegistryQueryInput">
                    <sxt:trace>
                        <sxt:log level="info" location="onStart">
                            <from variable="RespondingGateway_CrossGatewayQueryIn"/>
                        </sxt:log>
                        <sxt:log level="warning" location="onStart">
                            <from>'Received document query...'</from>
                        </sxt:log>
                    </sxt:trace>
                    <copy>
                        <from>$RespondingGateway_CrossGatewayQueryIn.RespondingGateway_CrossGatewayQueryRequest/query:AdhocQueryRequest</from>
                        <to variable="DocumentRegistry_RegistryStoredQueryIn" part="body"/>
                    </copy>
                </assign>
                <invoke name="InvokeRegistryStoredQuery" partnerLink="AdapterComponentDocQueryPL" operation="DocumentRegistry_RegistryStoredQuery" xmlns:ihe="urn:ihe:iti:xds-b:2007" portType="ihe:DocumentRegistry_PortType" inputVariable="DocumentRegistry_RegistryStoredQueryIn" outputVariable="DocumentRegistry_RegistryStoredQueryOut"/>
                <assign name="AssignRegistryStoredQueryOutput">
                    <copy>
                        <from variable="DocumentRegistry_RegistryStoredQueryOut" part="body"/>
                        <to variable="RespondingGateway_CrossGatewayQueryOut" part="RespondingGateway_CrossGatewayQueryResponse"/>
                    </copy>
                    <copy>
                        <from>'urn:oasis:names:tc:ebxml-regrep:ResponseStatusType:Success'</from>
                        <to>$RespondingGateway_CrossGatewayQueryOut.RespondingGateway_CrossGatewayQueryResponse/@status</to>
                    </copy>
                </assign>
                <reply name="ReplyDocQuery" partnerLink="AdapterDocQueryPL" operation="RespondingGateway_CrossGatewayQuery" xmlns:tns="urn:gov:hhs:fha:nhinc:adapterdocquery" portType="tns:AdapterDocQueryPortType" variable="RespondingGateway_CrossGatewayQueryOut">
                <sxt:trace>
                <sxt:log level="info" location="onStart">
                    <from>'End AdapterDocQuery - Response Message is:'</from>
                </sxt:log>
                <sxt:log level="info" location="onStart">
                    <from variable="RespondingGateway_CrossGatewayQueryOut"/>
                </sxt:log>
            </sxt:trace>
                </reply>
            </sequence>
        </scope>
    </sequence>
</process>