Menu
▾
▴
[Cse-ip-svn-commits] SF.net SVN: cse-ip:[406] trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src /AddCourse.bpel
|
From: <pka...@us...> - 2009-07-30 18:10:19
|
Revision: 406
http://cse-ip.svn.sourceforge.net/cse-ip/?rev=406&view=rev
Author: pkasprzak
Date: 2009-07-30 18:09:59 +0000 (Thu, 30 Jul 2009)
Log Message:
-----------
* Variable assignment fixes + non-working logging...
Modified Paths:
--------------
trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel
Modified: trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel
===================================================================
--- trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel 2009-07-30 18:08:24 UTC (rev 405)
+++ trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/AddCourse.bpel 2009-07-30 18:09:59 UTC (rev 406)
@@ -7,6 +7,7 @@
xmlns:sxed="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor"
xmlns:sxat="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Attachment"
xmlns:sxeh="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/ErrorHandling"
+ xmlns:sxxf="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/XPathFunctions"
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"
@@ -126,8 +127,8 @@
<assign name="prepareCreateMapping">
<!-- Set cse-id -->
<copy>
- <from>$CseId</from>
- <to>$CreateMappingIn.parameters/cseId</to>
+ <from variable="CseId"/>
+ <to>$CreateMappingIn.parameters/cseId/text()</to>
</copy>
<!-- Set system -->
<copy>
@@ -182,7 +183,7 @@
<assign name="prepareProcessRelations">
<copy>
- <from>$CseId</from>
+ <from variable="CseId"/>
<to>$ProcessCourseRelationsIn.parameters/cseId</to>
</copy>
<copy>
@@ -203,7 +204,7 @@
<assign name="prepareWaitForDependencies">
<copy>
- <from>$CseId</from>
+ <from variable="CseId"/>
<to>$WaitForDependenciesIn.parameters/entityId</to>
</copy>
</assign>
@@ -216,20 +217,42 @@
<correlation set="DependencyManager" initiate="yes"/>
</correlations>
</invoke>
+
+ <!-- Nothing to do! -->
<assign name="prepareGetOutboundSystems">
- <!-- Nothing to do! -->
<copy>
- <from></from>
+ <from>
+ <literal>
+ <getOutboundSystems/>
+ </literal>
+ </from>
<to>$GetOutboundSystemsIn.parameters</to>
</copy>
</assign>
+ <empty>
+ <sxt:trace>
+ <sxt:log level="info" location="onStart">
+ <ns0:from>'*** Before getOutboundSystems()'</ns0:from>
+ </sxt:log>
+ </sxt:trace>
+ </empty>
+
<invoke name="getOutboundSystems" partnerLink="SystemManager" operation="getOutboundSystems"
xmlns:tns="http://cse.campussource.de/ejb/SystemManager"
portType="tns:SystemManager"
inputVariable="GetOutboundSystemsIn"
outputVariable="GetOutboundSystemsOut"/>
+ <!-- test -->
+ <empty>
+ <sxt:trace>
+ <sxt:log level="info" location="onStart">
+ <ns0:from>concat('*** After getOutboundSystems():', sxxf:doMarshal($GetOutboundSystemsOut.parameters))</ns0:from>
+ </sxt:log>
+ </sxt:trace>
+ </empty>
+
<forEach name="Distribute" parallel="no" counterName="SystemCounter">
<startCounterValue>1</startCounterValue>
@@ -239,7 +262,9 @@
<variables>
<variable name="NotifyIn" messageType="ns0:notifyRequest"/>
+
<variable name="System" type="xsd:string"/>
+ <variable name="EntityId" type="xsd:int"/>
</variables>
<sequence name="Sequence2">
@@ -248,21 +273,31 @@
operation="notify"
portType="ns0:DependencyManagerNotification"
variable="NotifyIn">
+ <sxt:trace>
+ <sxt:log level="info" location="onStart">
+ <ns0:from>concat('*** Waiting for notification...', '')</ns0:from>
+ </sxt:log>
+ </sxt:trace>
+
<correlations>
<correlation set="DependencyManager" initiate="no"/>
</correlations>
</receive>
- <assign name="getSystem">
+ <assign name="setSystem">
<sxt:trace>
<sxt:log level="info" location="onComplete">
- <ns0:from>concat('*** Distributing message to system: ', $System)</ns0:from>
+ <ns0:from>concat('*** Received notification: (', $System, ',', $EntityId, ')')</ns0:from>
</sxt:log>
</sxt:trace>
<copy>
- <from>$GetOutboundSystemsOut.parameters/return[$SystemCounter]</from>
+ <from>$NotifyIn.system</from>
<to>$System</to>
</copy>
+ <copy>
+ <from>$NotifyIn.entityId</from>
+ <to>$EntityId</to>
+ </copy>
</assign>
<empty name="loadContext">
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
