initial commit

Author: suba

Rakefile

@@ -83,10 +83,10 @@ define "ode" do
   desc "ODE Axis Integration Layer"
   define "axis2" do
     compile.with projects("bpel-api", "bpel-connector", "bpel-dao", "bpel-epr", "bpel-runtime",
-      "scheduler-simple", "bpel-schemas", "bpel-store", "utils", "agents"),
+      "scheduler-simple", "bpel-schemas", "bpel-store", "utils", "agents", "clustering"),
       AXIOM, AXIS2_ALL, COMMONS.lang, COMMONS.collections, COMMONS.httpclient, COMMONS.lang,
       DERBY, GERONIMO.kernel, GERONIMO.transaction, JAVAX.activation, JAVAX.servlet, JAVAX.stream,
-      JAVAX.transaction, JENCKS, WSDL4J, WS_COMMONS, XMLBEANS, AXIS2_MODULES.libs, SLF4J, LOG4J
+      JAVAX.transaction, JENCKS, WSDL4J, WS_COMMONS, XMLBEANS, AXIS2_MODULES.libs, SLF4J, LOG4J, HAZELCAST
 
     test.exclude 'org.apache.ode.axis2.management.*'
     test.with project("tools"), AXIOM, JAVAX.javamail, COMMONS.codec, COMMONS.httpclient, XERCES, WOODSTOX
@@ -99,12 +99,12 @@ define "ode" do
     libs = projects("axis2", "bpel-api", "bpel-compiler", "bpel-connector", "bpel-dao",
       "bpel-epr", "bpel-obj", "bpel-ql", "bpel-runtime", "scheduler-simple",
       "bpel-schemas", "bpel-store", "dao-hibernate", "jca-ra", "jca-server",
-      "utils", "dao-jpa", "agents"),
+      "utils", "dao-jpa", "agents", "clustering"),
       AXIS2_ALL, ANNONGEN, BACKPORT, COMMONS.codec, COMMONS.collections, COMMONS.fileupload, COMMONS.io, COMMONS.httpclient, COMMONS.beanutils,
       COMMONS.lang, COMMONS.pool, DERBY, DERBY_TOOLS, JACOB, JAXEN, JAVAX.activation, JAVAX.ejb, JAVAX.javamail,
       JAVAX.connector, JAVAX.jms, JAVAX.persistence, JAVAX.transaction, JAVAX.stream,  JIBX,
       GERONIMO.connector, GERONIMO.kernel, GERONIMO.transaction, LOG4J, OPENJPA, SAXON, TRANQL,
-      WOODSTOX, WSDL4J, WS_COMMONS, XALAN, XERCES, XMLBEANS, SPRING, AXIS2_MODULES.libs, SLF4J, LOG4J
+      WOODSTOX, WSDL4J, WS_COMMONS, XALAN, XERCES, XMLBEANS, SPRING, AXIS2_MODULES.libs, SLF4J, LOG4J, HAZELCAST
 
     package(:war).with(:libs=>libs).path("WEB-INF").tap do |web_inf|
       web_inf.merge project("dao-jpa-ojpa-derby").package(:zip)
@@ -166,7 +166,7 @@ define "ode" do
 
   desc "ODE APIs"
   define "bpel-api" do
-    compile.with projects("utils", "bpel-obj", "bpel-schemas"), WSDL4J, XERCES, SLF4J, LOG4J
+    compile.with projects("utils", "bpel-obj", "bpel-schemas"), WSDL4J, XERCES, SLF4J, LOG4J, HAZELCAST
     package :jar
   end
 
@@ -206,6 +206,12 @@ define "ode" do
     package :jar
   end
 
+  desc "ODE Clustering"
+   define "clustering" do
+     compile.with projects("bpel-api"),HAZELCAST, COMMONS.logging
+     package :jar
+   end
+
   desc "ODE BPEL Object Model"
   define "bpel-obj" do
     compile.with project("utils"), SAXON, WSDL4J, COMMONS.collections
@@ -225,7 +231,7 @@ define "ode" do
   desc "ODE Runtime Engine"
   define "bpel-runtime" do
     compile.with projects("bpel-api", "bpel-compiler", "bpel-dao", "bpel-epr", "bpel-obj", "bpel-schemas",
-      "bpel-store", "utils", "agents"),
+      "bpel-store", "utils", "agents","clustering"),
       COMMONS.collections, COMMONS.httpclient, JACOB, JAVAX.persistence, JAVAX.stream, JAXEN, SAXON, WSDL4J, XMLBEANS, SPRING, SLF4J, LOG4J
 
 

axis2/src/main/java/org/apache/ode/axis2/ODEServer.java

@@ -82,6 +82,9 @@
 import org.apache.ode.utils.GUID;
 import org.apache.ode.utils.fs.TempFileManager;
 
+import org.apache.ode.clustering.hazelcast.*;
+import com.hazelcast.core.*;
+
 /**
  * Server class called by our Axis hooks to handle all ODE lifecycle management.
  *
@@ -133,6 +136,14 @@ public class ODEServer {
 
     public Runnable txMgrCreatedCallback;
 
+    private HazelcastInstanceConfig hazelcastInstanceConfig;
+
+    private HazelcastClusterImpl hazelcastClusterImpl;
+
+    private String clusteringState = "";
+
+    private boolean isClusteringEnabled;
+
     public void init(ServletConfig config, ConfigurationContext configContext) throws ServletException {
         init(config.getServletContext().getRealPath("/WEB-INF"), configContext);
     }
@@ -184,6 +195,11 @@ public void init(String contextPath, ConfigurationContext configContext, ODEConf
         if (txMgrCreatedCallback != null) {
             txMgrCreatedCallback.run();
         }
+
+        clusteringState = _odeConfig.getClusteringState();
+        if (isClusteringEnabled()) initClustering();
+        else __log.info("Clustering has not been initialized");
+
         __log.debug("Creating data source.");
         initDataSource();
         __log.debug("Starting DAO.");
@@ -455,6 +471,39 @@ private void initConnector() throws ServletException {
         }
     }
 
+    public boolean isClusteringEnabled() {
+        boolean state;
+        if (clusteringState.equals("true")) state = true;
+        else state = false;
+        setClustering(state);
+        return state;
+    }
+
+    public void  setClustering (boolean state) {
+        isClusteringEnabled = state;
+    }
+
+    public boolean getClusteringState() {
+        return isClusteringEnabled;
+    }
+
+    /**
+     * Initialize the clustering if it is enabled
+     */
+    private void initClustering() {
+        String hzConfig = System.getProperty("hazelcast.config");
+        if (hzConfig != null) hazelcastInstanceConfig = new HazelcastInstanceConfig();
+        else {
+            File hzXml = new File(_configRoot, "hazelcast.xml");
+            if (!hzXml.isFile())
+                __log.error("hazelcast.xml does not exist or is not a file");
+            else hazelcastInstanceConfig = new HazelcastInstanceConfig(hzXml);
+        }
+        if (hazelcastInstanceConfig != null) {
+            hazelcastClusterImpl = new HazelcastClusterImpl(hazelcastInstanceConfig.getHazelcastInstance());
+        }
+    }
+
     /**
      * Initialize the DAO.
      *
@@ -533,6 +582,7 @@ public Thread newThread(Runnable r) {
         _bpelServer.setCronScheduler(_cronScheduler);
 
         _bpelServer.setDaoConnectionFactory(_daoCF);
+        _bpelServer.setHazelcastCluster(hazelcastClusterImpl);
         _bpelServer.setInMemDaoConnectionFactory(new BpelDAOConnectionFactoryImpl(_scheduler, _odeConfig.getInMemMexTtl()));
         _bpelServer.setEndpointReferenceContext(eprContext);
         _bpelServer.setMessageExchangeContext(new MessageExchangeContextImpl(this));

bpel-api/src/main/java/org/apache/ode/bpel/hzapi/HazelcastCluster.java

@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.ode.bpel.hzapi;
+
+import com.hazelcast.core.Member;
+
+import java.util.List;
+
+public interface HazelcastCluster {
+
+    /**
+     * Initialization of the cluster
+     */
+    void init();
+
+    /**
+     * Get hostName + port nu of Member
+     * @param member
+     * @return
+     */
+    String getHazelCastNodeID(Member member);
+
+    /**
+     * Check whether current node is the leader or not.
+     */
+    void isLeader();
+
+    /**
+     * returns Current Nodes in the cluster.
+     * @return
+     */
+    List<String> getKnownNodes();
+
+    /**
+     * Return isMaster
+     * @return
+     */
+    boolean getIsMaster();
+
+}

bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java

@@ -59,6 +59,7 @@
 import org.apache.ode.bpel.iapi.Scheduler.Synchronizer;
 import org.apache.ode.bpel.intercept.MessageExchangeInterceptor;
 import org.apache.ode.bpel.o.OProcess;
+import org.apache.ode.clustering.hazelcast.HazelcastClusterImpl;
 import org.apache.ode.utils.msg.MessageBundle;
 import org.apache.ode.utils.stl.CollectionsX;
 import org.apache.ode.utils.stl.MemberOfFunction;
@@ -534,6 +535,10 @@ public void setBindingContext(BindingContext bc) {
         _contexts.bindingContext = bc;
     }
 
+    public void setHazelcastCluster(HazelcastClusterImpl hzCImpl) {
+        _contexts.hazelcastClusterImpl = hzCImpl;
+    }
+
     public DebuggerContext getDebugger(QName pid) throws BpelEngineException {
         return _engine._activeProcesses.get(pid)._debugger;
     }

bpel-runtime/src/main/java/org/apache/ode/bpel/engine/Contexts.java

@@ -28,6 +28,7 @@
 import org.apache.ode.bpel.intercept.MessageExchangeInterceptor;
 import org.apache.ode.bpel.engine.cron.CronScheduler;
 import org.apache.ode.bpel.evar.ExternalVariableModule;
+import org.apache.ode.clustering.hazelcast.HazelcastClusterImpl;
 
 import java.util.HashMap;
 import java.util.List;
@@ -46,6 +47,8 @@ public class Contexts {
 
     public CronScheduler cronScheduler;
 
+    public  HazelcastClusterImpl hazelcastClusterImpl;
+
     EndpointReferenceContext eprContext;
 
     BindingContext bindingContext;

clustering/pom.xml

@@ -0,0 +1,30 @@
+<?xml version="1.0"?>
+<!--
+~ Licensed to the Apache Software Foundation (ASF) under one
+~ or more contributor license agreements. See the NOTICE file
+~ distributed with this work for additional information
+~ regarding copyright ownership. The ASF licenses this file
+~ to you under the Apache License, Version 2.0 (the
+~ "License"); you may not use this file except in compliance
+~ with the License. You may obtain a copy of the License at
+~
+~ http://www.apache.org/licenses/LICENSE-2.0
+~
+~ Unless required by applicable law or agreed to in writing,
+~ software distributed under the License is distributed on an
+~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+~ KIND, either express or implied. See the License for the
+~ specific language governing permissions and limitations
+~ under the License.
+-->
+<project>
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>org.apache.ode</groupId>
+    <artifactId>ode-clustering</artifactId>
+    <name>ODE :: Clustering</name>
+    <parent>
+        <groupId>org.apache.ode</groupId>
+        <artifactId>ode</artifactId>
+        <version>1.4-SNAPSHOT</version>
+    </parent>
+</project>

clustering/src/main/java/org/apache/ode/clustering/Test.java

@@ -0,0 +1,4 @@
+package org.apache.ode.clustering;
+
+public class Test {
+}