ode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From va...@apache.org
Subject 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
Date Sun, 07 Oct 2007 22:21:55 GMT
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.");
                 }
             }
         }



Mime
View raw message