OPEN - issue ODE-160: ExtensionActivity and ExtensionAssignOperation:…

… Runtime support http://issues.apache.org/jira/browse/ODE-160 IL integration git-svn-id: https://svn.apache.org/repos/asf/ode/trunk@582691 13f79535-47bb-0310-9956-ffa450edef68
apache · Oct 7, 2007 · 1d5fa18 · 1d5fa18
1 parent 1e8798c
commit 1d5fa18
Show file tree

Hide file tree

Showing 3 changed files with 44 additions and 0 deletions.
diff --git a/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java b/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
@@ -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 @@ public void init(ServletConfig config, AxisConfiguration axisConf) throws Servle
             registerEventListeners();
 
             registerMexInterceptors();
+
+            registerExtensionActivityBundles();
 
             try {
                 _server.start();
@@ -508,6 +511,22 @@ private void registerMexInterceptors() {
         }
     }
 
+ 	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.");
+                }
+            }
+        }
+    }
+
     private class ProcessStoreListenerImpl implements ProcessStoreListener {
 
         public void onProcessStoreEvent(ProcessStoreEvent event) {

diff --git a/il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java b/il-common/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java
@@ -82,6 +82,8 @@ public class OdeConfigProperties {
     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;
 
@@ -268,4 +270,8 @@ public String getDbInternalPassword() {
         return getProperty(PROP_DB_INTERNAL_PASSWORD);
     }
 
+    public String getExtensionActivityBundles() {
+    	return getProperty(PROP_EXTENSION_BUNDLES);
+    }
+
 }
diff --git a/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java b/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java
@@ -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 @@ public void init(ComponentContext context) throws JBIException {
             registerEventListeners();
 
             registerMexInterceptors();
+
+            registerExtensionActivityBundles();
 
             __log.debug("Starting JCA connector.");
             initConnector();
@@ -291,6 +294,22 @@ private void registerMexInterceptors() {
         }
     }
 
+ 	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.");
+                }
+            }
+        }
+    }
+
     public synchronized void start() throws JBIException {
         if (_started)
             return;