You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2006/12/20 17:18:57 UTC
svn commit: r489129 - in /incubator/ode/trunk:
axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
Author: mriou
Date: Wed Dec 20 08:18:57 2006
New Revision: 489129
URL: http://svn.apache.org/viewvc?view=rev&rev=489129
Log:
Allowing moving the server directory around after process ahev been deployed. DU paths were absolute.
Modified:
incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
Modified: incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java?view=diff&rev=489129&r1=489128&r2=489129
==============================================================================
--- incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java (original)
+++ incubator/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java Wed Dec 20 08:18:57 2006
@@ -433,6 +433,7 @@
private void initProcessStore() {
_store = new ProcessStoreImpl(_datasource, _dialect);
_store.registerListener(new ProcessStoreListenerImpl());
+ _store.setDeployDir(new File(_workRoot, "processes"));
}
private void initBpelServer() {
Modified: incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java?view=diff&rev=489129&r1=489128&r2=489129
==============================================================================
--- incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java (original)
+++ incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java Wed Dec 20 08:18:57 2006
@@ -65,6 +65,8 @@
private String _guid = new GUID().toString();
private DbConfStoreConnectionFactory _cf;
+
+ private File _deployDir;
/**
* Executor used to process DB transactions. Allows us to isolate the TX context, and to ensure that only one TX gets executed a
@@ -195,7 +197,10 @@
dudao = conn.createDeploymentUnit(du.getName());
try {
- dudao.setDeploymentUnitDir(deploymentUnitDirectory.getCanonicalPath());
+ if (_deployDir == null)
+ dudao.setDeploymentUnitDir(deploymentUnitDirectory.getCanonicalPath());
+ else
+ dudao.setDeploymentUnitDir(deploymentUnitDirectory.getName());
} catch (IOException e1) {
String errmsg = "Error getting canonical path for " + du.getName()
+ "; deployment unit will not be available after restart!";
@@ -514,7 +519,10 @@
__log.debug("Loading deployment unit record from db: " + dudao.getName());
- File dudir = new File(dudao.getDeploymentUnitDir());
+ File dudir;
+ if (_deployDir == null) dudir = new File(dudao.getDeploymentUnitDir());
+ else dudir = new File(_deployDir, dudao.getDeploymentUnitDir());
+
if (!dudir.exists())
throw new ContextException("Deployed directory " + dudir + " no longer there!");
DeploymentUnitDir dud = new DeploymentUnitDir(dudir);
@@ -591,6 +599,10 @@
}
abstract V call(ConfStoreConnection conn);
+ }
+
+ public void setDeployDir(File depDir) {
+ _deployDir = depDir;
}
}