You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by bo...@apache.org on 2006/07/19 02:45:12 UTC

svn commit: r423315 - /incubator/ode/scratch/pxe-iapi/bpel-runtime/src/main/java/com/fs/pxe/bpel/engine/BpelProcess.java

Author: boisvert
Date: Tue Jul 18 17:45:11 2006
New Revision: 423315

URL: http://svn.apache.org/viewvc?rev=423315&view=rev
Log:
Pass EPRs during endpoint activation

Modified:
    incubator/ode/scratch/pxe-iapi/bpel-runtime/src/main/java/com/fs/pxe/bpel/engine/BpelProcess.java

Modified: incubator/ode/scratch/pxe-iapi/bpel-runtime/src/main/java/com/fs/pxe/bpel/engine/BpelProcess.java
URL: http://svn.apache.org/viewvc/incubator/ode/scratch/pxe-iapi/bpel-runtime/src/main/java/com/fs/pxe/bpel/engine/BpelProcess.java?rev=423315&r1=423314&r2=423315&view=diff
==============================================================================
--- incubator/ode/scratch/pxe-iapi/bpel-runtime/src/main/java/com/fs/pxe/bpel/engine/BpelProcess.java (original)
+++ incubator/ode/scratch/pxe-iapi/bpel-runtime/src/main/java/com/fs/pxe/bpel/engine/BpelProcess.java Tue Jul 18 17:45:11 2006
@@ -84,17 +84,22 @@
   private Map<QName, PartnerLinkMyRoleImpl> _serviceMap  = 
     new HashMap<QName,PartnerLinkMyRoleImpl>();
 
+  private Map<Integer,Element> _myEprs;
+    
+    
   private Set<EndpointReference> _myEndpoints = new HashSet<EndpointReference>();
 
   public BpelProcess(BpelEngineImpl engine, QName pid, 
       OProcess oprocess,
       Map<Integer,QName> serviceNames,
+      Map<Integer,Element> myEprs,
       BpelEventListener debugger,
       ExpressionLanguageRuntimeRegistry expLangRuntimeRegistry) {
     _pid = pid;
     _engine = engine;
     _replacementMap = new ReplacementMapImpl(oprocess);
     _oprocess = oprocess;
+    _myEprs = myEprs;
     _expLangRuntimeRegistry = expLangRuntimeRegistry;
 
     for (OPartnerLink pl : _oprocess.getAllPartnerLinks()) {
@@ -157,6 +162,7 @@
       mex.setPortOp(target._plinkDef.myRolePortType,target._plinkDef.getMyRoleOperation(mex.getOperationName()));
     }
   }
+  
   /**
    * Extract the value of a BPEL property from a BPEL messsage variable.
    * 
@@ -508,7 +514,8 @@
 
     @SuppressWarnings("unchecked")
     private Operation getMyRoleOperation(String operationName) {
-      return _plinkDef.getMyRoleOperation(operationName);
+      Operation op = _plinkDef.getMyRoleOperation(operationName);
+      return op;
     }
 
     private CorrelationKey[] computeCorrelationKeys(
@@ -652,9 +659,10 @@
   }
 
   void activate() {
-    for (QName svc : _serviceMap.keySet()) 
-      _myEndpoints.add(_engine._contexts.eprContext.activateEndpoint(_pid,svc,null));
-    
+    for (QName svc : _serviceMap.keySet()) {
+      PartnerLinkMyRoleImpl pm = _serviceMap.get(svc);
+      _myEndpoints.add(_engine._contexts.eprContext.activateEndpoint(_pid,svc,_myEprs.get(pm._plinkDef.getId())));
+    }
   }
   
   void deactivate() {