Author: ruwan
Date: Sun Feb 28 03:27:16 2010
New Revision: 917110
URL: http://svn.apache.org/viewvc?rev=917110&view=rev
Log:
Adding Task hot deployment
Added:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TaskDeployer.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Startup.java
synapse/trunk/java/repository/conf/axis2.xml
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Startup.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Startup.java?rev=917110&r1=917109&r2=917110&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Startup.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/Startup.java
Sun Feb 28 03:27:16 2010
@@ -46,4 +46,19 @@
* @param id String name to be set to the startup
*/
public void setName(String id);
+
+ /**
+ * Returns the name of the file where this startup is defined
+ *
+ * @return a file name as a string or null
+ */
+ public String getFileName();
+
+
+ /**
+ * Set the name of the file name where this startup is defined
+ *
+ * @param fileName the name of the file as a string
+ */
+ public void setFileName(String fileName);
}
Added:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TaskDeployer.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TaskDeployer.java?rev=917110&view=auto
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TaskDeployer.java
(added)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TaskDeployer.java
Sun Feb 28 03:27:16 2010
@@ -0,0 +1,176 @@
+/*
+ * 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.synapse.deployers;
+
+import org.apache.axiom.om.OMElement;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.synapse.ServerManager;
+import org.apache.synapse.Startup;
+import org.apache.synapse.config.xml.MultiXMLConfigurationBuilder;
+import org.apache.synapse.config.xml.StartupFinder;
+
+import java.io.File;
+
+/**
+ * Handles the <code>Startup Task</code> deployment and undeployment
+ *
+ * @see org.apache.synapse.deployers.AbstractSynapseArtifactDeployer
+ */
+public class TaskDeployer extends AbstractSynapseArtifactDeployer {
+
+ private static Log log = LogFactory.getLog(TaskDeployer.class);
+
+ @Override
+ public String deploySynapseArtifact(OMElement artifactConfig, String
fileName) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask Deployment from file : " + fileName + " :
Started");
+ }
+
+ try {
+ Startup st =
StartupFinder.getInstance().getStartup(artifactConfig);
+ st.setFileName((new File(fileName).getName()));
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask named '" + st.getName()
+ + "' has been built from the file " + fileName);
+ }
+ st.init(getSynapseEnvironment());
+ if (log.isDebugEnabled()) {
+ log.debug("Initialized the StartupTask : " + st.getName());
+ }
+ getSynapseConfiguration().addStartup(st);
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask Deployment from file : " + fileName
+ " : Completed");
+ }
+ log.info("StartupTask named '" + st.getName()
+ + "' has been deployed from file : " + fileName);
+ return st.getName();
+ } catch (Exception e) {
+ handleSynapseArtifactDeploymentError(
+ "StartupTask Deployment from the file : " + fileName + " :
Failed.", e);
+ }
+
+ return null;
+ }
+
+ @Override
+ public String updateSynapseArtifact(OMElement artifactConfig, String
fileName,
+ String existingArtifactName) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask Update from file : " + fileName + " :
Started");
+ }
+
+ try {
+ Startup st =
StartupFinder.getInstance().getStartup(artifactConfig);
+ st.setFileName((new File(fileName)).getName());
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask named '" + st.getName()
+ + "' has been built from the file " + fileName);
+ }
+ st.init(getSynapseEnvironment());
+ if (log.isDebugEnabled()) {
+ log.debug("Initialized the StartupTask : " + st.getName());
+ }
+ Startup existingSt =
+
getSynapseConfiguration().getStartup(existingArtifactName);
+ getSynapseConfiguration().removeStartup(existingArtifactName);
+ if (!existingArtifactName.equals(st.getName())) {
+ log.info("StartupTask named '" + existingArtifactName + "'
has been Undeployed");
+ }
+ getSynapseConfiguration().addStartup(st);
+ existingSt.destroy();
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask " +
(existingArtifactName.equals(st.getName()) ?
+ "update" : "deployment") + " from file : " +
fileName + " : Completed");
+ }
+ log.info("StartupTask named '" + st.getName()
+ + "' has been " +
(existingArtifactName.equals(st.getName()) ?
+ "update" : "deployed") + " from file : " +
fileName);
+ return st.getName();
+ } catch (Exception e) {
+ handleSynapseArtifactDeploymentError(
+ "StartupTask Update from the file : " + fileName + " :
Failed.", e);
+ }
+
+ return null;
+ }
+
+ @Override
+ public void undeploySynapseArtifact(String artifactName) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask Undeployment of the task named : "
+ + artifactName + " : Started");
+ }
+
+ try {
+ Startup st = getSynapseConfiguration().getStartup(artifactName);
+ if (st != null) {
+ getSynapseConfiguration().removeStartup(artifactName);
+ if (log.isDebugEnabled()) {
+ log.debug("Destroying the StartupTask named : " +
artifactName);
+ }
+ st.destroy();
+ if (log.isDebugEnabled()) {
+ log.debug("StartupTask Undeployment of the sequence named
: "
+ + artifactName + " : Completed");
+ }
+ log.info("StartupTask named '" + st.getName() + "' has been
undeployed");
+ } else {
+ log.error("Couldn't find the StartupTask named : " +
artifactName);
+ }
+ } catch (Exception e) {
+ handleSynapseArtifactDeploymentError(
+ "StartupTask Undeployement of task named : " +
artifactName + " : Failed", e);
+ }
+ }
+
+ @Override
+ public void restoreSynapseArtifact(String artifactName) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("Restoring the StartupTask with name : " + artifactName
+ " : Started");
+ }
+
+ try {
+ Startup st = getSynapseConfiguration().getStartup(artifactName);
+ OMElement stElem =
StartupFinder.getInstance().serializeStartup(null, st);
+ if (st.getFileName() != null) {
+ String fileName = ServerManager.getInstance()
+
.getServerConfigurationInformation().getSynapseXMLLocation()
+ + File.separator +
MultiXMLConfigurationBuilder.TASKS_DIR
+ + File.separator + st.getFileName();
+ writeToFile(stElem, fileName);
+ if (log.isDebugEnabled()) {
+ log.debug("Restoring the StartupTask with name : " +
artifactName + " : Completed");
+ }
+ log.info("StartupTask named '" + artifactName + "' has been
restored");
+ } else {
+ handleSynapseArtifactDeploymentError("Couldn't restore the
StartupTask named '"
+ + artifactName + "', filename cannot be found");
+ }
+ } catch (Exception e) {
+ handleSynapseArtifactDeploymentError(
+ "Restoring of the StartupTask named '" + artifactName + "'
has failed", e);
+ }
+ }
+}
Modified: synapse/trunk/java/repository/conf/axis2.xml
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/axis2.xml?rev=917110&r1=917109&r2=917110&view=diff
==============================================================================
--- synapse/trunk/java/repository/conf/axis2.xml (original)
+++ synapse/trunk/java/repository/conf/axis2.xml Sun Feb 28 03:27:16 2010
@@ -87,6 +87,7 @@
<deployer extension="xml" directory="conf/synapse-config/local-entries"
class="org.apache.synapse.deployers.LocalEntryDeployer"/>
<deployer extension="xml" directory="conf/synapse-config/proxy-services"
class="org.apache.synapse.deployers.ProxyServiceDeployer"/>
<deployer extension="xml" directory="conf/synapse-config/event-sources"
class="org.apache.synapse.deployers.EventSourceDeployer"/>
+ <deployer extension="xml" directory="conf/synapse-config/tasks"
class="org.apache.synapse.deployers.TaskDeployer"/>
<!-- Following parameter will set the host name for the epr-->
<!--<parameter name="hostname" locked="true">myhost.com</parameter>-->
