[Cse-ip-svn-commits] SF.net SVN: cse-ip:[406] trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src /AddCourse.bpel

[<pka...@us...>]

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.