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. |