Menu
▾
▴
[Cse-ip-svn-commits] SF.net SVN: cse-ip:[389] trunk/sandbox/lsf-adapter-demo/ObjectProcessor
|
From: <pka...@us...> - 2009-07-28 14:38:36
|
Revision: 389
http://cse-ip.svn.sourceforge.net/cse-ip/?rev=389&view=rev
Author: pkasprzak
Date: 2009-07-28 14:38:25 +0000 (Tue, 28 Jul 2009)
Log Message:
-----------
* Stuff :)
Modified Paths:
--------------
trunk/sandbox/lsf-adapter-demo/ObjectProcessor/catalog.xml
trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel
Modified: trunk/sandbox/lsf-adapter-demo/ObjectProcessor/catalog.xml
===================================================================
--- trunk/sandbox/lsf-adapter-demo/ObjectProcessor/catalog.xml 2009-07-28 14:38:15 UTC (rev 388)
+++ trunk/sandbox/lsf-adapter-demo/ObjectProcessor/catalog.xml 2009-07-28 14:38:25 UTC (rev 389)
@@ -7,4 +7,6 @@
<system systemId="Common/RelationManager.wsdl" uri="nb-uri:Common#src/RelationManager.wsdl"/>
<system systemId="Common/IdentityManager.wsdl" uri="nb-uri:Common#src/IdentityManager.wsdl"/>
<system systemId="Common/DependencyManagerNotification.wsdl" uri="nb-uri:Common#src/DependencyManagerNotification.wsdl"/>
+ <system systemId="Common/DependencyManager.wsdl" uri="nb-uri:Common#src/DependencyManager.wsdl"/>
+ <system systemId="Common/SystemManager.wsdl" uri="nb-uri:Common#src/SystemManager.wsdl"/>
</catalog>
Modified: trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel
===================================================================
--- trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel 2009-07-28 14:38:15 UTC (rev 388)
+++ trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel 2009-07-28 14:38:25 UTC (rev 389)
@@ -9,13 +9,16 @@
xmlns:sxeh="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/ErrorHandling"
xmlns:x="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
xmlns:dt="http://cse.campussource.de/schema/DataTypes"
- xmlns:tns="http://enterprise.netbeans.org/bpel/ObjectProcessor/AddCourse">
-
- <import namespace="http://j2ee.netbeans.org/wsdl/ObjectProcessor/AddCourse" location="AddCourse.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
- <import namespace="http://cse.campussource.de/ejb/EntityManager" location="Common/EntityManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
- <import namespace="http://cse.campussource.de/ejb/RelationManager" location="Common/RelationManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
- <import namespace="http://cse.campussource.de/ejb/IdentityManager" location="Common/IdentityManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
- <import namespace="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" location="Common/DependencyManagerNotification.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
+ xmlns:tns="http://enterprise.netbeans.org/bpel/ObjectProcessor/AddCourse"
+ xmlns:ns0="http://cse.campussource.de/ejb/DependencyManager">
+
+ <import namespace="http://j2ee.netbeans.org/wsdl/ObjectProcessor/AddCourse" location="AddCourse.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
+ <import namespace="http://cse.campussource.de/ejb/EntityManager" location="Common/EntityManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
+ <import namespace="http://cse.campussource.de/ejb/RelationManager" location="Common/RelationManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
+ <import namespace="http://cse.campussource.de/ejb/IdentityManager" location="Common/IdentityManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
+ <import namespace="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" location="Common/DependencyManagerNotification.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
+ <import namespace="http://cse.campussource.de/ejb/DependencyManager" location="Common/DependencyManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
+ <import namespace="http://cse.campussource.de/ejb/SystemManager" location="Common/SystemManager.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/>
<partnerLinks>
<partnerLink name="EntityManager" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" partnerLinkType="tns:EntityManagerLinkType"
partnerRole="EntityManagerRole"/>
@@ -26,13 +29,24 @@
<partnerLink name="IdentityManager" xmlns:tns="http://cse.campussource.de/ejb/IdentityManager" partnerLinkType="tns:IdentityManagerLinkType"
partnerRole="IdentityManagerRole"/>
+ <partnerLink name="DependencyManager" xmlns:tns="http://cse.campussource.de/ejb/DependencyManager" partnerLinkType="tns:DependencyManagerLinkType"
+ partnerRole="DependencyManagerRole"/>
+
+ <partnerLink name="SystemManager" xmlns:tns="http://cse.campussource.de/ejb/SystemManager" partnerLinkType="tns:SystemManagerLinkType"
+ partnerRole="SystemManagerRole"/>
+
<partnerLink name="ClientAdapter" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/AddCourse" partnerLinkType="tns:AddCourse"
myRole="AddCoursePortTypeRole"/>
- <partnerLink name="DependencyManager" xmlns:tns="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" partnerLinkType="tns:DependencyManagerNotification" myRole="DependencyManagerNotificationPortTypeRole"/>
+
+ <partnerLink name="DependencyManagerNotification" xmlns:tns="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" partnerLinkType="tns:DependencyManagerNotification"
+ myRole="DependencyManagerNotificationPortTypeRole"/>
</partnerLinks>
<variables>
- <variable name="NotifyIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" messageType="tns:notifyRequest"/>
+ <variable name="GetOutboundSystemsOut" xmlns:tns="http://cse.campussource.de/ejb/SystemManager" messageType="tns:getOutboundSystemsResponse"/>
+ <variable name="GetOutboundSystemsIn" xmlns:tns="http://cse.campussource.de/ejb/SystemManager" messageType="tns:getOutboundSystems"/>
+ <variable name="WaitForDependenciesIn" xmlns:tns="http://cse.campussource.de/ejb/DependencyManager" messageType="tns:waitForDependencies"/>
+ <variable name="NotifyIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" messageType="tns:notifyRequest"/>
<variable name="ProcessCourseRelationsOut" xmlns:tns="http://cse.campussource.de/ejb/RelationManager" messageType="tns:processCourseRelationsResponse"/>
<variable name="ProcessCourseRelationsIn" xmlns:tns="http://cse.campussource.de/ejb/RelationManager" messageType="tns:processCourseRelations"/>
<variable name="UpdateAttributesOut" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:updateAttributesResponse"/>
@@ -48,6 +62,10 @@
<variable name="CseId" type="xsd:integer"/>
</variables>
+ <correlationSets>
+ <correlationSet name="DependencyManager" properties="ns0:EntityId"/>
+ </correlationSets>
+
<sequence>
<receive name="start" createInstance="yes" partnerLink="ClientAdapter" operation="processCourse"
xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/AddCourse"
@@ -182,15 +200,35 @@
portType="tns:RelationManager"
inputVariable="ProcessCourseRelationsIn"
outputVariable="ProcessCourseRelationsOut"/>
- <empty name="checkDeps">
- <documentation>Check deps asynchronisly (i.e.) wait for callback, when deps are satisfied
-IN: OBJ_ID [course], OBJ_TYPE [type]
-OUT: -> callback
- </documentation>
- </empty>
- <pick name="Pick1">
- <onMessage partnerLink="DependencyManager" operation="notify" xmlns:tns="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" portType="tns:DependencyManagerNotificationPortType" variable="NotifyIn">
- <sequence name="Sequence1">
+
+ <assign name="prepareWaitForDependencies">
+ <copy>
+ <from>$CseId</from>
+ <to>$WaitForDependenciesIn.parameters/entityId</to>
+ </copy>
+ </assign>
+
+ <invoke name="waitForDependencies" partnerLink="DependencyManager" operation="waitForDependencies"
+ xmlns:tns="http://cse.campussource.de/ejb/DependencyManager"
+ portType="tns:DependencyManager"
+ inputVariable="WaitForDependenciesIn"/>
+ <assign name="prepareGetOutboundSystems">
+ <!-- Nothing to do! -->
+ <copy>
+ <from></from>
+ <to>$GetOutboundSystemsIn.parameters</to>
+ </copy>
+ </assign>
+
+ <invoke name="getOutboundSystems" partnerLink="SystemManager" operation="getOutboundSystems"
+ xmlns:tns="http://cse.campussource.de/ejb/SystemManager"
+ portType="tns:SystemManager"
+ inputVariable="GetOutboundSystemsIn"
+ outputVariable="GetOutboundSystemsOut"/>
+ <forEach name="ForEach1" parallel="no" counterName="ForEach1Counter">
+ <scope name="Scope1">
+ <sequence name="Sequence2">
+ <receive name="Receive1" createInstance="no" partnerLink="DependencyManagerNotification" operation="notify" xmlns:tns="http://j2ee.netbeans.org/wsdl/Common/DependencyManagerNotification" portType="tns:DependencyManagerNotificationPortType" variable="NotifyIn"/>
<empty name="loadContext">
<documentation>Load context for this entity for distribution (e.g. relations / parent objects / paths) and return it as xml (e.g. messages-object)</documentation>
</empty>
@@ -198,8 +236,8 @@
<documentation>Send courseMessage + context to outboundadapter (synchronisouly)</documentation>
</empty>
</sequence>
- </onMessage>
- </pick>
+ </scope>
+ </forEach>
<empty name="finish"/>
</sequence>
</process>
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
