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() {