source: ccr/trunk/nhin-vista/projects/NHINC/Current/Product/Production/Gateway/NhinBPEL/src/NhinNotify.bpel@ 507

Last change on this file since 507 was 507, checked in by George Lilly, 15 years ago

NHIN gateway and adaptor for use on linux with VistA EHR and RPMS
File size: 34.4 KB
Line 
1<?xml version="1.0" encoding="UTF-8"?>
2<process
3 name="NhinNotify"
4 targetNamespace="urn:gov:hhs:fha:nhinc:gateway:nhinbpel:nhinnotify"
5 xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
6 xmlns:xsd="http://www.w3.org/2001/XMLSchema"
7 xmlns:sxt="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Trace"
8 xmlns:sxed="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor"
9 xmlns:sxat="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Attachment"
10 xmlns:sxeh="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/ErrorHandling"
11 xmlns:tns="urn:gov:hhs:fha:nhinc:gateway:nhinbpel:nhinnotify"
12 xmlns:propacc="urn:gov:hhs:fha:nhinc:common:propertyaccess"
13 xmlns:conninfo="urn:gov:hhs:fha:nhinc:common:connectionmanagerinfo"
14 xmlns:nccommon="urn:gov:hhs:fha:nhinc:common:nhinccommon"
15 xmlns:bpel="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
16 xmlns:wsnt="http://docs.oasis-open.org/wsn/b-2"
17 xmlns:nhinccommonintorch="urn:gov:hhs:fha:nhinc:common:nhinccommoninternalorch"
18 xmlns:nccommonadapter="urn:gov:hhs:fha:nhinc:common:nhinccommonadapter"
19 xmlns:nccommonsub="urn:gov:hhs:fha:nhinc:common:subscription"
20 xmlns:subdte="urn:gov:hhs:fha:nhinc:common:subscriptiondte"
21 xmlns:hiemauditlog="urn:gov:hhs:fha:nhinc:common:hiemauditlog"
22 xmlns:auditlog="urn:gov:hhs:fha:nhinc:common:auditlog">
23 <import namespace="urn:gov:hhs:fha:nhinc:nhincsubscription" location="Interfaces/wsdl/NhincSubscription.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
24 <import namespace="http://docs.oasis-open.org/wsrf/rw-2" location="Interfaces/wsdl/rw-2.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
25 <import namespace="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" location="Interfaces/wsdl/NhincComponentPropAccessor.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
26 <import namespace="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" location="Interfaces/wsdl/NhincComponentInternalSubscriptionDte.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
27 <import namespace="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" location="Interfaces/wsdl/NhincComponentSubscriptionReferenceRepository.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
28 <import namespace="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" location="Interfaces/wsdl/NhincComponentConnectionManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
29 <import namespace="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" location="Interfaces/wsdl/AdapterNotificationConsumer.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
30 <import namespace="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" location="Interfaces/wsdl/NhincComponentInternalAuditRepository.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
31 <partnerLinks>
32 <partnerLink name="AuditRepoPL" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" partnerLinkType="tns:NhincComponentInternalAuditRepository" partnerRole="NhincComponentInternalAuditRepositoryPortTypeRole"/>
33 <partnerLink name="PropertyAccessorPL" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" partnerLinkType="tns:NhincComponentPropAccessor" partnerRole="NhincComponentPropAccessorPortTypeRole"/>
34 <partnerLink name="SubscriptionDtePL" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" partnerLinkType="tns:NhincComponentInternalSubscriptionDte" partnerRole="NhincComponentInternalSubscriptionDtePortTypeRole"/>
35 <partnerLink name="SubscriptionRefRepoPL" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" partnerLinkType="tns:NhincComponentSubscriptionReferenceRepository" partnerRole="NhincComponentSubscriptionReferenceRepositoryPortTypeRole"/>
36 <partnerLink name="ConnectionManagerPL" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" partnerLinkType="tns:NhincComponentConnectionManager" partnerRole="NhincComponentConnectionManagerPortTypeRole"/>
37 <partnerLink name="AdapterNotifyPL" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" partnerLinkType="tns:AdapterNotificationConsumer" partnerRole="AdapterNotificationConsumerPortTypeRole"/>
38 <partnerLink name="NhincNotifyPL" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincsubscription" partnerLinkType="tns:NhincHiemNotify" myRole="NhincHiemNotifyRole"/>
39 </partnerLinks>
40 <variables>
41 <variable name="RetrieveBySubRefOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" messageType="tns:RetrieveBySubscriptionReferenceResponse"/>
42 <variable name="RetrieveBySubRefIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" messageType="tns:RetrieveBySubscriptionReferenceRequest"/>
43 <variable name="TransformNotifyToSubRefOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:TransformNhinNotifyToInternalSubscriptionReferenceResponseMessage"/>
44 <variable name="TransformNotifyToSubRefIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:TransformNhinNotifyToInternalSubscriptionReferenceRequestMessage"/>
45 <variable name="PassthruNotifyOut" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" messageType="tns:NotifyResponseMessage"/>
46 <variable name="PassthruNotifyIn" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" messageType="tns:NotifyRequestMessage"/>
47 <variable name="GetHcidPropertyOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" messageType="tns:GetPropertyResponseMessage"/>
48 <variable name="GetHcidPropertyIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" messageType="tns:GetPropertyRequestMessage"/>
49 <variable name="GetAdapterEndpointOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" messageType="tns:GetConnectionInfoEndpointByServiceNameResponseMessage"/>
50 <variable name="GetAdapterEndpointIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" messageType="tns:GetConnectionInfoEndpointByServiceNameRequestMessage"/>
51 <variable name="GetAdapterPassthruEndpointOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" messageType="tns:GetConnectionInfoEndpointByServiceNameResponseMessage"/>
52 <variable name="GetAdapterPassthruEndpointIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" messageType="tns:GetConnectionInfoEndpointByServiceNameRequestMessage"/>
53 <variable name="GetPassthruPropertyOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" messageType="tns:GetPropertyBooleanResponseMessage"/>
54 <variable name="GetPassthruPropertyIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" messageType="tns:GetPropertyBooleanRequestMessage"/>
55 <variable name="GetServicePropertyOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" messageType="tns:GetPropertyBooleanResponseMessage"/>
56 <variable name="GetServicePropertyIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" messageType="tns:GetPropertyBooleanRequestMessage"/>
57 <variable name="NotifyIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincsubscription" messageType="tns:NotifyRequestMessage"/>
58 </variables>
59 <sequence>
60 <receive name="ReceiveNhincNotify" createInstance="yes" partnerLink="NhincNotifyPL" operation="Notify" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincsubscription" portType="tns:NotificationConsumer" variable="NotifyIn"/>
61 <scope name="ProcessNotifyScope">
62 <variables>
63 <variable name="LogAdapterPtNotifyRespOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" messageType="tns:LogEventResponseMessage"/>
64 <variable name="LogAdapterPtNotifyRespIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" messageType="tns:LogEntityNotifyRespRequestMessage"/>
65 <variable name="LogAdapterPtNotifyRequestOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" messageType="tns:LogEventResponseMessage"/>
66 <variable name="LogAdapterPtNotifyRequestIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" messageType="tns:LogNhinNotifyRequestMessage"/>
67 <variable name="LogNhinNotifyRequestOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" messageType="tns:LogEventResponseMessage"/>
68 <variable name="LogNhinNotifyRequestIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" messageType="tns:LogNhinNotifyRequestMessage"/>
69 <variable name="NotifySubscribersOfCdcBioPackageOut" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" messageType="tns:NotifySubscribersOfCdcBioPackageResponseMessage"/>
70 <variable name="NotifySubscribersOfCdcBioPackageIn" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" messageType="tns:NotifySubscribersOfCdcBioPackageRequestMessage"/>
71 <variable name="CreateAgencyNotifyCdcBioPackageOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:CreateAgencyNotifyCdcBioPackageResponseMessage"/>
72 <variable name="CreateAgencyNotifyCdcBioPackageIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:CreateAgencyNotifyCdcBioPackageRequestMessage"/>
73 <variable name="NotifySubscribersOfDocumentOut" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" messageType="tns:NotifySubscribersOfDocumentResponseMessage"/>
74 <variable name="NotifySubscribersOfDocumentIn" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" messageType="tns:NotifySubscribersOfDocumentRequestMessage"/>
75 <variable name="CreateAgencyNotifyDocOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:CreateAgencyNotifyDocumentResponseMessage"/>
76 <variable name="CreateAgencyNotifyDocIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:CreateAgencyNotifyDocumentRequestMessage"/>
77 <variable name="DetermineTopicOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:DetermineRootTopicFromNotifyResponseMessage"/>
78 <variable name="DetermineTopicIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" messageType="tns:DetermineRootTopicFromNotifyRequestMessage"/>
79 <variable name="RetrieveByAgencySubRefOut" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" messageType="tns:RetrieveBySubscriptionReferenceResponse"/>
80 <variable name="RetrieveByAgencySubRefIn" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" messageType="tns:RetrieveBySubscriptionReferenceRequest"/>
81 </variables>
82 <sequence name="ProcessNotifySeq">
83 <assign name="AssignAuditNhinNotify">
84 <copy>
85 <from>$NotifyIn.NotifyRequest/wsnt:Notify</from>
86 <to>$LogNhinNotifyRequestIn.LogNhinNotifyRequest/hiemauditlog:message/wsnt:Notify</to>
87 </copy>
88 <copy>
89 <from>$NotifyIn.NotifyRequest/nhinccommonintorch:assertion</from>
90 <to>$LogNhinNotifyRequestIn.LogNhinNotifyRequest/hiemauditlog:message/nhinccommonintorch:assertion</to>
91 </copy>
92 <copy>
93 <from>'Nhin'</from>
94 <to>$LogNhinNotifyRequestIn.LogNhinNotifyRequest/auditlog:interface</to>
95 </copy>
96 <copy>
97 <from>'Inbound'</from>
98 <to>$LogNhinNotifyRequestIn.LogNhinNotifyRequest/auditlog:direction</to>
99 </copy>
100 </assign>
101 <invoke name="InvokeAuditNhinNotify" partnerLink="AuditRepoPL" operation="LogNhinNotifyRequest" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" portType="tns:NhincComponentInternalAuditRepositoryPortType" inputVariable="LogNhinNotifyRequestIn" outputVariable="LogNhinNotifyRequestOut"/>
102 <assign name="AssignNotifyServiceProperty">
103 <copy>
104 <from>'gateway'</from>
105 <to>$GetServicePropertyIn.GetPropertyBooleanRequest/propacc:propertyFile</to>
106 </copy>
107 <copy>
108 <from>'serviceNotify'</from>
109 <to>$GetServicePropertyIn.GetPropertyBooleanRequest/propacc:propertyName</to>
110 </copy>
111 </assign>
112 <invoke name="InvokeNotifyServiceProperty" partnerLink="PropertyAccessorPL" operation="GetPropertyBoolean" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" portType="tns:NhincComponentPropAccessorPortType" inputVariable="GetServicePropertyIn" outputVariable="GetServicePropertyOut"/>
113 <if name="IfNotifyServiceEnabled">
114 <condition>$GetServicePropertyOut.GetPropertyBooleanResponse/propacc:propertyValue = true()</condition>
115 <sequence name="NotifyServiceEnabledSeq">
116 <assign name="AssignLocalHcidProperty">
117 <copy>
118 <from>'gateway'</from>
119 <to>$GetHcidPropertyIn.GetPropertyRequest/propacc:propertyFile</to>
120 </copy>
121 <copy>
122 <from>'localHomeCommunityId'</from>
123 <to>$GetHcidPropertyIn.GetPropertyRequest/propacc:propertyName</to>
124 </copy>
125 </assign>
126 <invoke name="InvokeLocalHcidProperty" partnerLink="PropertyAccessorPL" operation="GetProperty" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" portType="tns:NhincComponentPropAccessorPortType" inputVariable="GetHcidPropertyIn" outputVariable="GetHcidPropertyOut"/>
127 <assign name="AssignNotifyPassthruProperty">
128 <copy>
129 <from>'gateway'</from>
130 <to>$GetPassthruPropertyIn.GetPropertyBooleanRequest/propacc:propertyFile</to>
131 </copy>
132 <copy>
133 <from>'notifyPassthrough'</from>
134 <to>$GetPassthruPropertyIn.GetPropertyBooleanRequest/propacc:propertyName</to>
135 </copy>
136 </assign>
137 <invoke name="InvokeNotifyPassthruProperty" partnerLink="PropertyAccessorPL" operation="GetPropertyBoolean" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentpropaccessor" portType="tns:NhincComponentPropAccessorPortType" inputVariable="GetPassthruPropertyIn" outputVariable="GetPassthruPropertyOut"/>
138 <if name="IfNotPassthru">
139 <condition>$GetPassthruPropertyOut.GetPropertyBooleanResponse/propacc:propertyValue = false()</condition>
140 <sequence name="NotPassthurSeq">
141 <empty name="Placeholder_PE"/>
142 <assign name="AssignTransformToSubRef">
143 <copy>
144 <from>$NotifyIn.NotifyRequest/wsnt:Notify</from>
145 <to>$TransformNotifyToSubRefIn.TransformNhinNotifyToInternalSubscriptionReference/wsnt:Notify</to>
146 </copy>
147 </assign>
148 <invoke name="InvokeTransformToSubRef" partnerLink="SubscriptionDtePL" operation="TransformNhinNotifyToInternalSubscriptionReference" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" portType="tns:NhincComponentInternalSubscriptionDtePortType" inputVariable="TransformNotifyToSubRefIn" outputVariable="TransformNotifyToSubRefOut"/>
149 <assign name="AssignRetrieveSubRef">
150 <copy>
151 <from>$TransformNotifyToSubRefOut.TransformNhinNotifyToInternalSubscriptionReference/nccommonsub:SubscriptionReference</from>
152 <to>$RetrieveBySubRefIn.RetrieveBySubscriptionReferenceMessage/nccommonsub:SubscriptionReference</to>
153 </copy>
154 </assign>
155 <invoke name="InvokeRetrieveSubRef" partnerLink="SubscriptionRefRepoPL" operation="RetrieveBySubscriptionReference" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" portType="tns:NhincComponentSubscriptionReferenceRepositoryPortType" inputVariable="RetrieveBySubRefIn" outputVariable="RetrieveBySubRefOut"/>
156 <assign name="AssignRetrieveParentSubRef">
157 <copy>
158 <from>$RetrieveBySubRefOut.SubscriptionItem/nccommonsub:ParentSubscriptionReference</from>
159 <to>$RetrieveByAgencySubRefIn.RetrieveBySubscriptionReferenceMessage/nccommonsub:SubscriptionReference</to>
160 </copy>
161 </assign>
162 <invoke name="InvokeRetrieveParentSubRef" partnerLink="SubscriptionRefRepoPL" operation="RetrieveBySubscriptionReference" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentsubscriptionreferencerepository" portType="tns:NhincComponentSubscriptionReferenceRepositoryPortType" inputVariable="RetrieveByAgencySubRefIn" outputVariable="RetrieveByAgencySubRefOut"/>
163 <assign name="AssignAdapterEndptLookup">
164 <copy>
165 <from>$GetHcidPropertyOut.GetPropertyResponse/propacc:propertyValue</from>
166 <to>$GetAdapterEndpointIn.GetConnectionInfoEndpointByServiceNameRequest/conninfo:homeCommunityWithServiceName/conninfo:homeCommunity/nccommon:homeCommunityId</to>
167 </copy>
168 <copy>
169 <from>'adapternotificationconsumer'</from>
170 <to>$GetAdapterEndpointIn.GetConnectionInfoEndpointByServiceNameRequest/conninfo:homeCommunityWithServiceName/conninfo:serviceName</to>
171 </copy>
172 </assign>
173 <invoke name="InvokeAdapterEndptLookup" partnerLink="ConnectionManagerPL" operation="GetConnectionInfoEndpointByServiceName" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" portType="tns:NhincComponentConnectionManagerPortType" inputVariable="GetAdapterEndpointIn" outputVariable="GetAdapterEndpointOut"/>
174 <assign name="AssignDetermineTopic">
175 <copy>
176 <from>$NotifyIn.NotifyRequest/wsnt:Notify</from>
177 <to>$DetermineTopicIn.DetermineRootTopicFromNotify/wsnt:Notify</to>
178 </copy>
179 </assign>
180 <invoke name="InvokeDetermineTopic" partnerLink="SubscriptionDtePL" operation="DetermineRootTopicFromNotify" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" portType="tns:NhincComponentInternalSubscriptionDtePortType" inputVariable="DetermineTopicIn" outputVariable="DetermineTopicOut"/>
181 <if name="DetermineTopic">
182 <condition>$DetermineTopicOut.DetermineRootTopicFromNotify/subdte:RootTopic = 'document'</condition>
183 <sequence name="NotifyDocumentSeq">
184 <assign name="AssignCreateAgencyNotifyDoc">
185 <copy>
186 <from>$NotifyIn.NotifyRequest/wsnt:Notify</from>
187 <to>$CreateAgencyNotifyDocIn.CreateAgencyNotifyDocumentRequest/wsnt:Notify</to>
188 </copy>
189 <copy>
190 <from>$RetrieveByAgencySubRefOut.SubscriptionItem/nccommonsub:SubscriptionReference</from>
191 <to>$CreateAgencyNotifyDocIn.CreateAgencyNotifyDocumentRequest/nccommonsub:SubscriptionReference</to>
192 </copy>
193 </assign>
194 <invoke name="InvokeCreateAgencyNotifyDoc" partnerLink="SubscriptionDtePL" operation="CreateAgencyNotifyDocument" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" portType="tns:NhincComponentInternalSubscriptionDtePortType" inputVariable="CreateAgencyNotifyDocIn" outputVariable="CreateAgencyNotifyDocOut"/>
195 <assign name="AssignAdapterNotifyDoc">
196 <copy>
197 <from>bpel:doXslTransform('urn:stylesheets:wrap2serviceref.xsl', $GetAdapterEndpointOut.ConnectionInfoEndpoint/conninfo:serviceConnectionInfoEndpoints/conninfo:serviceConnectionInfoEndpoint/nccommon:EPR/nccommon:EndpointReference)</from>
198 <to partnerLink="AdapterNotifyPL"/>
199 </copy>
200 <copy>
201 <from>$CreateAgencyNotifyDocOut.CreateAgencyNotifyDocumentResponse/nccommonadapter:NotifySubscribersOfDocumentRequest/nccommonadapter:notify</from>
202 <to>$NotifySubscribersOfDocumentIn.NotifySubscribersOfDocumentRequest/nccommonadapter:notify</to>
203 </copy>
204 <copy>
205 <from>$NotifyIn.NotifyRequest/nhinccommonintorch:assertion</from>
206 <to>$NotifySubscribersOfDocumentIn.NotifySubscribersOfDocumentRequest/nccommonadapter:assertion</to>
207 </copy>
208 </assign>
209 <empty name="Placeholder_Audit_AdpDocReq"/>
210 <invoke name="InvokeAdapterNotifyDoc" partnerLink="AdapterNotifyPL" operation="NotifySubscribersOfDocument" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" portType="tns:AdapterNotificationConsumerPortType" inputVariable="NotifySubscribersOfDocumentIn" outputVariable="NotifySubscribersOfDocumentOut"/>
211 <empty name="Placeholder_Audit_AdpDocResp"/>
212 </sequence>
213 <elseif>
214 <condition>$DetermineTopicOut.DetermineRootTopicFromNotify/subdte:RootTopic = 'nhin-cdc:CdcBioPackage'</condition>
215 <sequence name="NotifyCdcSeq">
216 <assign name="AssignCreateCdcBioPackageNotify">
217 <copy>
218 <from>$NotifyIn.NotifyRequest/wsnt:Notify</from>
219 <to>$CreateAgencyNotifyCdcBioPackageIn.CreateAgencyNotifyCdcBioPackage/wsnt:Notify</to>
220 </copy>
221 <copy>
222 <from>$RetrieveByAgencySubRefOut.SubscriptionItem/nccommonsub:SubscriptionReference</from>
223 <to>$CreateAgencyNotifyCdcBioPackageIn.CreateAgencyNotifyCdcBioPackage/nccommonsub:SubscriptionReference</to>
224 </copy>
225 </assign>
226 <invoke name="InvokeCreateCdcBioPackageNotify" partnerLink="SubscriptionDtePL" operation="CreateAgencyNotifyCdcBioPackage" xmlns:tns="urn:gov:hhs:fha:nhinc:nhincinternalcomponentpolicyenginetransform" portType="tns:NhincComponentInternalSubscriptionDtePortType" inputVariable="CreateAgencyNotifyCdcBioPackageIn" outputVariable="CreateAgencyNotifyCdcBioPackageOut"/>
227 <assign name="AssignAdapterNotifyCdcDoc">
228 <copy>
229 <from>bpel:doXslTransform('urn:stylesheets:wrap2serviceref.xsl', $GetAdapterEndpointOut.ConnectionInfoEndpoint/conninfo:serviceConnectionInfoEndpoints/conninfo:serviceConnectionInfoEndpoint/nccommon:EPR/nccommon:EndpointReference)</from>
230 <to partnerLink="AdapterNotifyPL"/>
231 </copy>
232 <copy>
233 <from>$NotifyIn.NotifyRequest/nhinccommonintorch:assertion</from>
234 <to>$NotifySubscribersOfCdcBioPackageIn.NotifySubscribersOfCdcBioPackageRequest/nccommonadapter:assertion</to>
235 </copy>
236 <copy>
237 <from>$CreateAgencyNotifyCdcBioPackageOut.CreateAgencyNotifyCdcBioPackage/nccommonadapter:NotifySubscribersOfCdcBioPackageRequest/nccommonadapter:notify</from>
238 <to>$NotifySubscribersOfCdcBioPackageIn.NotifySubscribersOfCdcBioPackageRequest/nccommonadapter:notify</to>
239 </copy>
240 </assign>
241 <empty name="Placeholder_Audit_AdpCdcReq"/>
242 <invoke name="InvokeAdapterNotifyCdcDoc" partnerLink="AdapterNotifyPL" operation="NotifySubscribersOfCdcBioPackage" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" portType="tns:AdapterNotificationConsumerPortType" inputVariable="NotifySubscribersOfCdcBioPackageIn" outputVariable="NotifySubscribersOfCdcBioPackageOut"/>
243 <empty name="Placeholder_Audit_AdpCdcResp"/>
244 </sequence>
245 </elseif>
246 <else>
247 <empty name="UnknownTopic">
248 <sxt:trace>
249 <sxt:log level="warning" location="onStart">
250 <bpel:from>concat('An Unknown topic was received: ', $DetermineTopicOut.DetermineRootTopicFromNotify/subdte:RootTopic)</bpel:from>
251 </sxt:log>
252 </sxt:trace>
253 </empty>
254 </else>
255 </if>
256 </sequence>
257 <else>
258 <sequence name="AdapterPassthruSeq">
259 <assign name="AssignAdapterPassthruEndptLookup">
260 <copy>
261 <from>$GetHcidPropertyOut.GetPropertyResponse/propacc:propertyValue</from>
262 <to>$GetAdapterPassthruEndpointIn.GetConnectionInfoEndpointByServiceNameRequest/conninfo:homeCommunityWithServiceName/conninfo:homeCommunity/nccommon:homeCommunityId</to>
263 </copy>
264 <copy>
265 <from>'adapternotificationconsumerpassthrough'</from>
266 <to>$GetAdapterPassthruEndpointIn.GetConnectionInfoEndpointByServiceNameRequest/conninfo:homeCommunityWithServiceName/conninfo:serviceName</to>
267 </copy>
268 </assign>
269 <invoke name="InvokeAdapterPassthruEndptLookup" partnerLink="ConnectionManagerPL" operation="GetConnectionInfoEndpointByServiceName" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentconnectionmanager" portType="tns:NhincComponentConnectionManagerPortType" inputVariable="GetAdapterPassthruEndpointIn" outputVariable="GetAdapterPassthruEndpointOut"/>
270 <assign name="AssignAdapterPassthru">
271 <copy>
272 <from>bpel:doXslTransform('urn:stylesheets:wrap2serviceref.xsl', $GetAdapterPassthruEndpointOut.ConnectionInfoEndpoint/conninfo:serviceConnectionInfoEndpoints/conninfo:serviceConnectionInfoEndpoint/nccommon:EPR/nccommon:EndpointReference)</from>
273 <to partnerLink="AdapterNotifyPL"/>
274 </copy>
275 <copy>
276 <from>$NotifyIn.NotifyRequest/wsnt:Notify</from>
277 <to>$PassthruNotifyIn.NotifyRequest/wsnt:Notify</to>
278 </copy>
279 <copy>
280 <from>$NotifyIn.NotifyRequest/nhinccommonintorch:assertion</from>
281 <to>$PassthruNotifyIn.NotifyRequest/nccommonadapter:assertion</to>
282 </copy>
283 </assign>
284 <assign name="AssignAuditAdapterNotifyReq">
285 <copy>
286 <from>$NotifyIn.NotifyRequest/wsnt:Notify</from>
287 <to>$LogAdapterPtNotifyRequestIn.LogNhinNotifyRequest/hiemauditlog:message/wsnt:Notify</to>
288 </copy>
289 <copy>
290 <from>$NotifyIn.NotifyRequest/nhinccommonintorch:assertion</from>
291 <to>$LogAdapterPtNotifyRequestIn.LogNhinNotifyRequest/hiemauditlog:message/nhinccommonintorch:assertion</to>
292 </copy>
293 <copy>
294 <from>'Outbound'</from>
295 <to>$LogAdapterPtNotifyRequestIn.LogNhinNotifyRequest/auditlog:direction</to>
296 </copy>
297 <copy>
298 <from>'Adapter'</from>
299 <to>$LogAdapterPtNotifyRequestIn.LogNhinNotifyRequest/auditlog:interface</to>
300 </copy>
301 </assign>
302 <invoke name="InvokeAuditAdapterNotifyReq" partnerLink="AuditRepoPL" operation="LogNhinNotifyRequest" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" portType="tns:NhincComponentInternalAuditRepositoryPortType" inputVariable="LogAdapterPtNotifyRequestIn" outputVariable="LogAdapterPtNotifyRequestOut"/>
303 <invoke name="InvokeAdapterPassthru" partnerLink="AdapterNotifyPL" operation="Notify" xmlns:tns="urn:gov:hhs:fha:nhinc:adapternotificationconsumer" portType="tns:AdapterNotificationConsumerPortType" inputVariable="PassthruNotifyIn" outputVariable="PassthruNotifyOut"/>
304 <assign name="AssignAuditAdapterNotifyResp">
305 <copy>
306 <from>$NotifyIn.NotifyRequest/nhinccommonintorch:assertion</from>
307 <to>$LogAdapterPtNotifyRespIn.LogEntityNotifyRespRequest/hiemauditlog:message/hiemauditlog:assertion</to>
308 </copy>
309 <copy>
310 <from>'Inbound'</from>
311 <to>$LogAdapterPtNotifyRespIn.LogEntityNotifyRespRequest/auditlog:direction</to>
312 </copy>
313 <copy>
314 <from>'Adapter'</from>
315 <to>$LogAdapterPtNotifyRespIn.LogEntityNotifyRespRequest/auditlog:interface</to>
316 </copy>
317 <copy>
318 <from variable="PassthruNotifyOut" part="NotifyResponse"/>
319 <to>$LogAdapterPtNotifyRespIn.LogEntityNotifyRespRequest/hiemauditlog:message/hiemauditlog:ack</to>
320 </copy>
321 </assign>
322 <invoke name="InvokeAuditAdapterNotifyResp" partnerLink="AuditRepoPL" operation="LogEntityNotifyRespRequest" xmlns:tns="urn:gov:hhs:fha:nhinc:nhinccomponentinternalauditrepository" portType="tns:NhincComponentInternalAuditRepositoryPortType" inputVariable="LogAdapterPtNotifyRespIn" outputVariable="LogAdapterPtNotifyRespOut"/>
323 </sequence>
324 </else>
325 </if>
326 </sequence>
327 </if>
328 </sequence>
329 </scope>
330 </sequence>
331</process>
Note: See TracBrowser for help on using the repository browser.