Skip to content

C
conductorderasynchron
Commit 4982da59 authored by Tiemo Bang's avatar Tiemo Bang
Browse files
Options

'Async'

parent 97cc7797
Hide whitespace changes
Inline Side-by-side
Showing with 1044 additions and 31 deletions
rev0/ConductOrder84.bpel
View file @ 4982da59
......@@ -82,6 +82,10 @@
<!-- Set of activities coordinating the flow of messages across the -->
<!-- services integrated within this business process -->
<!-- ================================================================= -->
<bpel:correlationSets>
<bpel:correlationSet name="newCorrelationSet" properties="tns:CustomerId"></bpel:correlationSet>
</bpel:correlationSets>
<bpel:sequence name="main">
<!-- Receive input from requester.
......@@ -93,7 +97,8 @@
<bpel:receive name="receiveInput" partnerLink="client"
portType="tns:ConductOrder84"
operation="process" variable="input"
createInstance="yes"/>
createInstance="yes">
</bpel:receive>
<!-- Generate reply to synchronous request -->
......@@ -141,8 +146,32 @@
</bpel:assign>
<bpel:flow name="Flow">
<bpel:sequence name="Sequence"><bpel:invoke name="storeOrderDetails" partnerLink="OrderPL" operation="storeOrderDetails" portType="ns:OrderPortType" outputVariable="storeOrderDetailsResponse" inputVariable="input"></bpel:invoke>
<bpel:flow name="Flow"><bpel:sequence name="Sequence"><bpel:invoke name="storeOrderDetails" partnerLink="OrderPL" operation="storeOrderDetails" portType="ns:OrderPortType" outputVariable="storeOrderDetailsResponse" inputVariable="input"></bpel:invoke>
<bpel:assign validate="no" name="assignOrderID"><bpel:copy>
<bpel:from><bpel:literal><tns:shipProducts xmlns:tns="http://iaas.uni-stuttgart.de/labs/FlowSOG" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<tns:orderId>tns:orderId</tns:orderId>
......@@ -263,7 +292,7 @@
<bpel:assign validate="no" name="assignProductIds">
<bpel:copy>
<bpel:from><bpel:literal xml:space="preserve"><tns:checkAvailabilityAsync xmlns:tns="http://iaas.uni-stuttgart.de/labs/FlowSOG" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<tns:callbackUrl>http://46.101.159.46:32930/InventoryCallbackService/onFinishCheckAvailability</tns:callbackUrl>
<tns:callbackUrl>http://46.101.159.46:32880/ode/processes/IntentoryCallbackService</tns:callbackUrl>
<tns:customerId>tns:customerId</tns:customerId>
<tns:productId>tns:productId</tns:productId>
</tns:checkAvailabilityAsync></bpel:literal></bpel:from>
......@@ -301,40 +330,25 @@
<bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[ns:productId[1]]]></bpel:query>
</bpel:to>
</bpel:copy>
</bpel:assign>
<!--
<bpel:invoke name="checkAvaAsyn" partnerLink="InventoryPL" operation="checkAvailabilityAsync" portType="ns:InventoryPortType" inputVariable="InventoryPLRequest"></bpel:invoke>
<bpel:receive name="onFinishCheckAvailabilty" partnerLink="InventroyCallBackPL" operation="onFinishCheckAvailability" variable="InventroyCallBackPLRequest"></bpel:receive>
-->
<bpel:invoke name="checkAvaAsyn" partnerLink="InventoryPL" operation="checkAvailabilityAsync" portType="ns:InventoryPortType" inputVariable="InventoryPLRequest">
<bpel:correlations>
<bpel:correlation set="newCorrelationSet" initiate="yes" ></bpel:correlation>
</bpel:correlations>
</bpel:invoke>
<bpel:receive name="onFinish" partnerLink="InventroyCallBackPL" operation="onFinishCheckAvailability" variable="InventroyCallBackPLRequest">
<bpel:correlations>
<bpel:correlation set="newCorrelationSet" initiate="no"></bpel:correlation>
</bpel:correlations>
</bpel:receive>
</bpel:sequence></bpel:flow>
</bpel:sequence>
</bpel:flow>
<bpel:invoke name="conductPayment" partnerLink="PaymentPL" operation="conductPayment" portType="ns:PaymentPortType" inputVariable="conductPaymentRequest" outputVariable="conductPaymentResponse"></bpel:invoke>
<bpel:invoke name="shipProducts" partnerLink="ShipmentPL" operation="shipProducts" portType="ns:ShipmentPortType" inputVariable="shipProductsRequest" outputVariable="shipProdctsResponse"></bpel:invoke>
......
rev0/ConductOrder84.bpelex
View file @ 4982da59
......@@ -18,7 +18,7 @@
</extensions>
<extensions>
<extendedObject href="ConductOrder84.bpel#/"/>
<extensionObject xsi:type="org.eclipse.bpel.ui.uiextensionmodel:ProcessExtension" modificationStamp="1479250854521" processName="{group12}ConductOrder84" processVersion="8"/>
<extensionObject xsi:type="org.eclipse.bpel.ui.uiextensionmodel:ProcessExtension" modificationStamp="1479519768342" processName="{group12}ConductOrder84" processVersion="8"/>
</extensions>
<extensions>
<extendedObject href="ConductOrder84.bpel#//@activity/@activities.1"/>
......
rev0/ConductOrder84.log
View file @ 4982da59
This source diff could not be displayed because it is too large. You can view the blob instead.
rev0/ConductOrder84Artifacts.wsdl
View file @ 4982da59
......@@ -26,6 +26,17 @@
<plnk:partnerLinkType name="InventroyCallbackPLT">
<plnk:role name="InventroyCaller" portType="wsdl:InventoryCallbackPortType"/>
</plnk:partnerLinkType>
<vprop:property name="CustomerId" type="xsd:string"/>
<vprop:propertyAlias messageType="wsdl:checkAvailabilityAsyncInput" part="checkAvailabilityAsyncInput" propertyName="tns:CustomerId">
<vprop:query><![CDATA[/wsdl:customerId]]></vprop:query>
</vprop:propertyAlias>
<vprop:propertyAlias messageType="wsdl:storeOrderDetailsInput" part="storeOrderDetailsInput" propertyName="tns:CustomerId">
<vprop:query><![CDATA[/wsdl:customerId]]></vprop:query>
</vprop:propertyAlias>
<vprop:propertyAlias messageType="wsdl:onFinishCheckAvailabilityInput" part="onFinishCheckAvailabilityInput" propertyName="tns:CustomerId">
<vprop:query><![CDATA[/wsdl:customerId]]></vprop:query>
</vprop:propertyAlias>
<import location="46.101.159.46.wsdl" namespace="http://iaas.uni-stuttgart.de/labs/FlowSOG"/>
<types>
<schema xmlns="http://www.w3.org/2001/XMLSchema" attributeFormDefault="unqualified" elementFormDefault="qualified" targetNamespace="group12">
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment