You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by ms...@apache.org on 2007/07/13 21:35:47 UTC
svn commit: r556120 -
/incubator/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java
Author: mszefler
Date: Fri Jul 13 12:35:47 2007
New Revision: 556120
URL: http://svn.apache.org/viewvc?view=rev&rev=556120
Log:
BART: remove BpelEngineImpl references.
Modified:
incubator/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java
Modified: incubator/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java?view=diff&rev=556120&r1=556119&r2=556120
==============================================================================
--- incubator/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java (original)
+++ incubator/ode/branches/bart/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/ProcessAndInstanceManagementImpl.java Fri Jul 13 12:35:47 2007
@@ -397,7 +397,7 @@
return null;
for (ActivityRecoveryDAO recovery : instance.getActivityRecoveries()) {
if (recovery.getActivityId() == aid) {
- BpelProcess process = _server._engine._activeProcesses.get(instance.getProcess().getProcessId());
+ BpelProcess process = _server.getBpelProcess(instance.getProcess().getProcessId());
if (process != null) {
process.recoverActivity(instance, recovery.getChannel(), aid, action, null);
break;
@@ -480,7 +480,7 @@
public ActivityExtInfoListDocument getExtensibilityElements(QName pid, Integer[] aids) {
ActivityExtInfoListDocument aeild = ActivityExtInfoListDocument.Factory.newInstance();
TActivitytExtInfoList taeil = aeild.addNewActivityExtInfoList();
- OProcess oprocess = _server._engine.getOProcess(pid);
+ OProcess oprocess = _server.getOProcess(pid);
for (int aid : aids) {
OBase obase = oprocess.getChild(aid);
@@ -516,7 +516,7 @@
*/
protected final DebuggerSupport getDebugger(QName procid) throws ManagementException {
- BpelProcess process = _server._engine._activeProcesses.get(procid);
+ BpelProcess process = _server.getBpelProcess(procid);
if (process == null)
throw new InvalidRequestException("The process \"" + procid + "\" is available.");
@@ -747,13 +747,13 @@
}
}
- OProcess oprocess = _server._engine.getOProcess(pconf.getProcessId());
+ OProcess oprocess = _server.getOProcess(pconf.getProcessId());
if (custom.includeEndpoints() && oprocess != null) {
TEndpointReferences eprs = info.addNewEndpoints();
for (OPartnerLink oplink : oprocess.getAllPartnerLinks()) {
if (oplink.hasPartnerRole() && oplink.initializePartnerRole) {
// TODO: this is very uncool.
- EndpointReference pepr = _server._engine._activeProcesses.get(pconf.getProcessId())
+ EndpointReference pepr = _server.getBpelProcess(pconf.getProcessId())
.getInitialPartnerRoleEPR(oplink);
if (pepr != null) {