Menu
▾
▴
[Cse-ip-svn-commits] SF.net SVN: cse-ip:[382] trunk/sandbox/lsf-adapter-demo/ObjectProcessor
|
From: <pka...@us...> - 2009-07-27 22:15:37
|
Revision: 382
http://cse-ip.svn.sourceforge.net/cse-ip/?rev=382&view=rev
Author: pkasprzak
Date: 2009-07-27 22:15:24 +0000 (Mon, 27 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-27 22:14:42 UTC (rev 381)
+++ trunk/sandbox/lsf-adapter-demo/ObjectProcessor/catalog.xml 2009-07-27 22:15:24 UTC (rev 382)
@@ -6,4 +6,5 @@
<system systemId="Common/EntityManager.wsdl" uri="nb-uri:Common#src/EntityManager.wsdl"/>
<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"/>
</catalog>
Modified: trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel
===================================================================
--- trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel 2009-07-27 22:14:42 UTC (rev 381)
+++ trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel 2009-07-27 22:15:24 UTC (rev 382)
@@ -15,26 +15,37 @@
<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/"/>
+ <partnerLinks>
+ <partnerLink name="EntityManager" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" partnerLinkType="tns:EntityManagerLinkType"
+ partnerRole="EntityManagerRole"/>
- <partnerLinks>
- <partnerLink name="EntityManager" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" partnerLinkType="tns:EntityManagerLinkType" partnerRole="EntityManagerRole"/>
- <partnerLink name="RelationManager" xmlns:tns="http://cse.campussource.de/ejb/RelationManager" partnerLinkType="tns:RelationManagerLinkType" partnerRole="RelationManagerRole"/>
- <partnerLink name="IdentityManager" xmlns:tns="http://cse.campussource.de/ejb/IdentityManager" partnerLinkType="tns:IdentityManagerLinkType" partnerRole="IdentityManagerRole"/>
- <partnerLink name="ClientAdapter" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/AddCourse" partnerLinkType="tns:AddCourse" myRole="AddCoursePortTypeRole"/>
+ <partnerLink name="RelationManager" xmlns:tns="http://cse.campussource.de/ejb/RelationManager" partnerLinkType="tns:RelationManagerLinkType"
+ partnerRole="RelationManagerRole"/>
+
+ <partnerLink name="IdentityManager" xmlns:tns="http://cse.campussource.de/ejb/IdentityManager" partnerLinkType="tns:IdentityManagerLinkType"
+ partnerRole="IdentityManagerRole"/>
+
+ <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"/>
</partnerLinks>
<variables>
- <variable name="UpdateAttributesOut" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:updateAttributesResponse"/>
- <variable name="UpdateAttributesIn" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:updateAttributes"/>
- <variable name="CreateMappingIn" xmlns:tns="http://cse.campussource.de/ejb/IdentityManager" messageType="tns:createMapping"/>
- <variable name="PersistCourseOut" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:persistCourseResponse"/>
- <variable name="PersistCourseIn" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:persistCourse"/>
- <variable name="ExistsOut" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:existsResponse"/>
- <variable name="ExistsIn" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:exists"/>
- <variable name="ProcessCourseIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/AddCourse" messageType="tns:processCourseRequest"/>
+ <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"/>
+ <variable name="UpdateAttributesIn" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:updateAttributes"/>
+ <variable name="CreateMappingIn" xmlns:tns="http://cse.campussource.de/ejb/IdentityManager" messageType="tns:createMapping"/>
+ <variable name="PersistCourseOut" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:persistCourseResponse"/>
+ <variable name="PersistCourseIn" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:persistCourse"/>
+ <variable name="ExistsOut" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:existsResponse"/>
+ <variable name="ExistsIn" xmlns:tns="http://cse.campussource.de/ejb/EntityManager" messageType="tns:exists"/>
+ <variable name="ProcessCourseIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/AddCourse" messageType="tns:processCourseRequest"/>
<!-- CSE-id of the course -->
- <variable name="CseId" type="xsd:integer"/>
+ <variable name="CseId" type="xsd:integer"/>
</variables>
<sequence>
@@ -56,7 +67,7 @@
</copy>
</assign>
- <invoke name="checkIfCourseExists" partnerLink="EntityManager" operation="exists"
+ <invoke name="checkIfCourseExists" partnerLink="EntityManager" operation="exists"
xmlns:tns="http://cse.campussource.de/ejb/EntityManager"
portType="tns:EntityManager"
inputVariable="ExistsIn"
@@ -132,15 +143,15 @@
if not changed => check if relations have changed (if they have => update; else process finished)</documentation>
</empty>
-
-
+
+
<assign name="prepareUpdateAttributes">
<copy>
<from>x:doXslTransform('urn:stylesheets:toEntity.xsl', $ProcessCourseIn.courseMessage/dt:course)</from>
<to>$UpdateAttributesIn.parameters/entity</to>
</copy>
</assign>
-
+
<invoke name="updateAttributes" partnerLink="EntityManager" operation="updateAttributes"
xmlns:tns="http://cse.campussource.de/ejb/EntityManager"
portType="tns:EntityManager"
@@ -151,30 +162,44 @@
</if>
- <empty name="checkRelations">
- <documentation>check if relations have changed (and persist changes);
+ <assign name="prepareProcessRelations">
+ <copy>
+ <from>$CseId</from>
+ <to>$ProcessCourseRelationsIn.parameters/cseId</to>
+ </copy>
+ <copy>
+ <from>$ProcessCourseIn.courseMessage/dt:course</from>
+ <to>$ProcessCourseRelationsIn.parameters/course</to>
+ </copy>
+ <copy>
+ <from>$ProcessCourseIn.courseMessage/dt:source</from>
+ <to>$ProcessCourseRelationsIn.parameters/system</to>
+ </copy>
+ </assign>
-if they have => UPDATE event
-else: => keep current event</documentation>
- </empty>
- <empty name="saveOrUpdateEntityData">
- <documentation>Check entity vs persistence (save / or update [attribute changes?])</documentation>
- </empty>
- <empty name="handleIds">
- <documentation>Save clientId / generate busId</documentation>
- </empty>
+ <invoke name="processRelations" partnerLink="RelationManager" operation="processCourseRelations"
+ xmlns:tns="http://cse.campussource.de/ejb/RelationManager"
+ 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>
- <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>
- <empty name="distributeMessages">
- <documentation>Send courseMessage + context to outboundadapter (synchronisouly)</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">
+ <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>
+ <empty name="distributeMessages">
+ <documentation>Send courseMessage + context to outboundadapter (synchronisouly)</documentation>
+ </empty>
+ </sequence>
+ </onMessage>
+ </pick>
<empty name="finish"/>
</sequence>
</process>
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
