You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by va...@apache.org on 2007/10/08 00:21:55 UTC
svn commit: r582691 - in /ode/trunk:
axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java
jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java
Author: vanto
Date: Sun Oct 7 15:21:47 2007
New Revision: 582691
URL: http://svn.apache.org/viewvc?rev=582691&view=rev
Log:
OPEN - issue ODE-160: ExtensionActivity and ExtensionAssignOperation: Runtime support
http://issues.apache.org/jira/browse/ODE-160
IL integration
Modified:
ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
ode/trunk/il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java
ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java
Modified: ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
URL: http://svn.apache.org/viewvc/ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java?rev=582691&r1=582690&r2=582691&view=diff
==============================================================================
--- ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java (original)
+++ ode/trunk/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java Sun Oct 7 15:21:47 2007
@@ -44,6 +44,7 @@
import org.apache.ode.axis2.service.ManagementService;
import org.apache.ode.bpel.connector.BpelServerConnector;
import org.apache.ode.bpel.dao.BpelDAOConnectionFactory;
+import org.apache.ode.bpel.eapi.AbstractExtensionBundle;
import org.apache.ode.bpel.engine.BpelServerImpl;
import org.apache.ode.bpel.engine.CountLRUDehydrationPolicy;
import org.apache.ode.bpel.evtproc.DebugBpelEventListener;
@@ -155,6 +156,8 @@
registerEventListeners();
registerMexInterceptors();
+
+ registerExtensionActivityBundles();
try {
_server.start();
@@ -503,6 +506,22 @@
} catch (Exception e) {
__log.warn("Couldn't register the event listener " + interceptorCN + ", the class couldn't be "
+ "loaded properly: " + e);
+ }
+ }
+ }
+ }
+
+ private void registerExtensionActivityBundles() {
+ String listenersStr = _odeConfig.getExtensionActivityBundles();
+ if (listenersStr != null) {
+ // TODO replace StringTokenizer by regex
+ for (StringTokenizer tokenizer = new StringTokenizer(listenersStr, ",;"); tokenizer.hasMoreTokens();) {
+ String bundleCN = tokenizer.nextToken();
+ try {
+ _server.registerExtensionBundle((AbstractExtensionBundle) Class.forName(bundleCN).newInstance());
+ } catch (Exception e) {
+ __log.warn("Couldn't register the extension bundle " + bundleCN + ", the class couldn't be " +
+ "loaded properly.");
}
}
}
Modified: ode/trunk/il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java
URL: http://svn.apache.org/viewvc/ode/trunk/il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java?rev=582691&r1=582690&r2=582691&view=diff
==============================================================================
--- ode/trunk/il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java (original)
+++ ode/trunk/il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java Sun Oct 7 15:21:47 2007
@@ -82,6 +82,8 @@
public static final String PROP_PROCESS_DEHYDRATION = "process.dehydration";
public static final String PROP_DAOCF = "dao.factory";
+
+ public static final String PROP_EXTENSION_BUNDLES= "extension.bundles";
private File _cfgFile;
@@ -266,6 +268,10 @@
public String getDbInternalPassword() {
return getProperty(PROP_DB_INTERNAL_PASSWORD);
+ }
+
+ public String getExtensionActivityBundles() {
+ return getProperty(PROP_EXTENSION_BUNDLES);
}
}
Modified: ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java
URL: http://svn.apache.org/viewvc/ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java?rev=582691&r1=582690&r2=582691&view=diff
==============================================================================
--- ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java (original)
+++ ode/trunk/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java Sun Oct 7 15:21:47 2007
@@ -36,6 +36,7 @@
import org.apache.commons.logging.LogFactory;
import org.apache.ode.bpel.connector.BpelServerConnector;
import org.apache.ode.bpel.dao.BpelDAOConnectionFactoryJDBC;
+import org.apache.ode.bpel.eapi.AbstractExtensionBundle;
import org.apache.ode.bpel.engine.BpelServerImpl;
import org.apache.ode.bpel.evtproc.DebugBpelEventListener;
import org.apache.ode.bpel.iapi.BpelEventListener;
@@ -115,6 +116,8 @@
registerEventListeners();
registerMexInterceptors();
+
+ registerExtensionActivityBundles();
__log.debug("Starting JCA connector.");
initConnector();
@@ -286,6 +289,22 @@
} catch (Exception e) {
__log.warn("Couldn't register the event listener " + interceptorCN + ", the class couldn't be "
+ "loaded properly: " + e);
+ }
+ }
+ }
+ }
+
+ private void registerExtensionActivityBundles() {
+ String listenersStr = _ode._config.getExtensionActivityBundles();
+ if (listenersStr != null) {
+ // TODO replace StringTokenizer by regex
+ for (StringTokenizer tokenizer = new StringTokenizer(listenersStr, ",;"); tokenizer.hasMoreTokens();) {
+ String bundleCN = tokenizer.nextToken();
+ try {
+ _ode._server.registerExtensionBundle((AbstractExtensionBundle) Class.forName(bundleCN).newInstance());
+ } catch (Exception e) {
+ __log.warn("Couldn't register the extension bundle " + bundleCN + ", the class couldn't be " +
+ "loaded properly.");
}
}
}