You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by su...@apache.org on 2011/03/28 11:09:20 UTC
svn commit: r1086160 - in /synapse/trunk/java:
modules/core/src/main/java/org/apache/synapse/config/
modules/core/src/main/java/org/apache/synapse/deployers/
modules/core/src/main/java/org/apache/synapse/mediators/template/
repository/conf/
Author: supun
Date: Mon Mar 28 09:09:20 2011
New Revision: 1086160
URL: http://svn.apache.org/viewvc?rev=1086160&view=rev
Log:
adding the template deployer
Added:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TemplateDeployer.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/SynapseConfiguration.java
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/template/TemplateMediator.java
synapse/trunk/java/repository/conf/axis2.xml
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/SynapseConfiguration.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/SynapseConfiguration.java?rev=1086160&r1=1086159&r2=1086160&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/SynapseConfiguration.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/SynapseConfiguration.java Mon Mar 28 09:09:20 2011
@@ -194,6 +194,21 @@ public class SynapseConfiguration implem
}
}
+ /**
+ * Update a sequence-template into the local registry. If a template already exists
+ * by the specified key a runtime exception is thrown.
+ *
+ * @param key the name for the sequence
+ * @param mediator a Sequence mediator
+ */
+ public synchronized void updateSequenceTemplate(String key, TemplateMediator mediator) {
+ localRegistry.put(key, mediator);
+
+ for (SynapseObserver o : observers) {
+ o.sequenceTemplateAdded(mediator);
+ }
+ }
+
public synchronized void updateSequence(String key, Mediator mediator) {
localRegistry.put(key, mediator);
for (SynapseObserver o : observers) {
@@ -1532,6 +1547,19 @@ public class SynapseConfiguration implem
localRegistry.put(name, template);
}
+ public void updateEndpointTemplate(String name, Template template) {
+ localRegistry.put(name, template);
+ }
+
+ public void removeEndpointTemplate(String name) {
+ Object sequence = localRegistry.get(name);
+ if (sequence instanceof Template) {
+ localRegistry.remove(name);
+ } else {
+ handleException("No template exists by the key/name : " + name);
+ }
+ }
+
public Template getEndpointTemplate(String key) {
Object o = getEntry(key);
if (o instanceof Template) {
Added: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TemplateDeployer.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TemplateDeployer.java?rev=1086160&view=auto
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TemplateDeployer.java (added)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/TemplateDeployer.java Mon Mar 28 09:09:20 2011
@@ -0,0 +1,287 @@
+/*
+ * 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.axis2.deployment.DeploymentException;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.synapse.Mediator;
+import org.apache.synapse.SynapseConstants;
+import org.apache.synapse.config.xml.MediatorFactoryFinder;
+import org.apache.synapse.config.xml.MultiXMLConfigurationBuilder;
+import org.apache.synapse.config.xml.TemplateMediatorSerializer;
+import org.apache.synapse.config.xml.endpoints.TemplateSerializer;
+import org.apache.synapse.endpoints.Template;
+import org.apache.synapse.mediators.template.TemplateMediator;
+
+import javax.xml.namespace.QName;
+import java.io.File;
+import java.util.Properties;
+
+public class TemplateDeployer extends AbstractSynapseArtifactDeployer {
+ private static Log log = LogFactory.getLog(TemplateDeployer.class);
+
+ @Override
+ public String deploySynapseArtifact(OMElement artifactConfig, String fileName, Properties properties) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("Template Deployment from file : " + fileName + " : Started");
+ }
+
+ try {
+
+ OMElement element = artifactConfig.getFirstChildWithName(
+ new QName(SynapseConstants.SYNAPSE_NAMESPACE, "endpoint"));
+ if (element != null) {
+ org.apache.synapse.config.xml.endpoints.TemplateFactory templateFactory =
+ new org.apache.synapse.config.xml.endpoints.TemplateFactory();
+
+ Template tm = templateFactory.createEndpointTemplate(artifactConfig, properties);
+
+ tm.setName(new File(fileName).getName());
+ if (log.isDebugEnabled()) {
+ log.debug("Sequence Template named '" + tm.getName()
+ + "' has been built from the file " + fileName);
+ }
+
+ getSynapseConfiguration().addEndpointTemplate(tm.getName(), tm);
+ if (log.isDebugEnabled()) {
+ log.debug("Template Deployment from file : " + fileName + " : Completed");
+ }
+ log.info("Template named '" + tm.getName()
+ + "' has been deployed from file : " + fileName);
+
+ return tm.getName();
+ } else {
+ element = artifactConfig.getFirstChildWithName(
+ new QName(SynapseConstants.SYNAPSE_NAMESPACE, "sequence"));
+ if (element != null) {
+ Mediator mediator = MediatorFactoryFinder.getInstance().
+ getMediator(artifactConfig, properties);
+ if (mediator instanceof TemplateMediator) {
+ TemplateMediator tm = (TemplateMediator) mediator;
+
+ tm.setFileName((new File(fileName)).getName());
+ if (log.isDebugEnabled()) {
+ log.debug("Sequence Template named '" + tm.getName()
+ + "' has been built from the file " + fileName);
+ }
+
+ tm.init(getSynapseEnvironment());
+ if (log.isDebugEnabled()) {
+ log.debug("Initialized the Template : " + tm.getName());
+ }
+
+ getSynapseConfiguration().addSequenceTemplate(tm.getName(), tm);
+ if (log.isDebugEnabled()) {
+ log.debug("Template Deployment from file : " + fileName + " : Completed");
+ }
+ log.info("Template named '" + tm.getName()
+ + "' has been deployed from file : " + fileName);
+
+ return tm.getName();
+ }
+ }
+ }
+
+ } catch (Exception e) {
+ handleSynapseArtifactDeploymentError(
+ "Template Deployment from the file : " + fileName + " : Failed.", e);
+ }
+
+ return null;
+ }
+
+ @Override
+ public String updateSynapseArtifact(OMElement artifactConfig, String fileName,
+ String existingArtifactName, Properties properties) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("Template update from file : " + fileName + " has started");
+ }
+
+ try {
+ OMElement element = artifactConfig.getFirstChildWithName(
+ new QName(SynapseConstants.SYNAPSE_NAMESPACE, "endpoint"));
+ if (element != null) {
+ org.apache.synapse.config.xml.endpoints.TemplateFactory templateFactory =
+ new org.apache.synapse.config.xml.endpoints.TemplateFactory();
+
+ Template tm = templateFactory.createEndpointTemplate(artifactConfig, properties);
+
+ tm.setName(new File(fileName).getName());
+ if (log.isDebugEnabled()) {
+ log.debug("Sequence Template named '" + tm.getName()
+ + "' has been built from the file " + fileName);
+ }
+
+ Template existingSt = getSynapseConfiguration().
+ getEndpointTemplate(existingArtifactName);
+
+ if (existingArtifactName.equals(tm.getName())) {
+ getSynapseConfiguration().updateEndpointTemplate(tm.getName(), existingSt);
+ } else {
+ getSynapseConfiguration().addEndpointTemplate(tm.getName(), tm);
+ getSynapseConfiguration().removeEndpointTemplate(existingSt.getName());
+ log.info("Template: " + existingArtifactName + " has been undeployed");
+ }
+
+ log.info("Template: " + tm.getName() + " has been updated from the file: " + fileName);
+ return tm.getName();
+ } else {
+ element = artifactConfig.getFirstChildWithName(
+ new QName(SynapseConstants.SYNAPSE_NAMESPACE, "sequence"));
+ if (element != null) {
+ Mediator mediator = MediatorFactoryFinder.getInstance().
+ getMediator(artifactConfig, properties);
+ if (mediator instanceof TemplateMediator) {
+ TemplateMediator tm = (TemplateMediator) mediator;
+
+ tm.setFileName((new File(fileName)).getName());
+ if (log.isDebugEnabled()) {
+ log.debug("Sequence Template named '" + tm.getName()
+ + "' has been built from the file " + fileName);
+ }
+
+ tm.init(getSynapseEnvironment());
+ if (log.isDebugEnabled()) {
+ log.debug("Initialized the Template : " + tm.getName());
+ }
+
+ TemplateMediator existingSt = getSynapseConfiguration().
+ getSequenceTemplate(existingArtifactName);
+
+ if (existingArtifactName.equals(tm.getName())) {
+ getSynapseConfiguration().updateSequenceTemplate(tm.getName(), existingSt);
+ } else {
+ getSynapseConfiguration().addSequenceTemplate(tm.getName(), tm);
+ getSynapseConfiguration().removeSequenceTemplate(existingSt.getName());
+ log.info("Template: " + existingArtifactName + " has been undeployed");
+ }
+
+ existingSt.destroy();
+ log.info("Template: " + tm.getName() + " has been updated from the file: " + fileName);
+ return tm.getName();
+ }
+ }
+ }
+
+ } catch (DeploymentException e) {
+ handleSynapseArtifactDeploymentError("Error while updating the Template from the " +
+ "file: " + fileName);
+ }
+
+ return null;
+ }
+
+ @Override
+ public void undeploySynapseArtifact(String artifactName) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("Template Undeployment of the Template named : "
+ + artifactName + " : Started");
+ }
+
+ try {
+ Template st = getSynapseConfiguration().getEndpointTemplate(artifactName);
+ if (st != null) {
+ getSynapseConfiguration().removeEndpointTemplate(artifactName);
+ if (log.isDebugEnabled()) {
+ log.debug("Destroying the Template named : " + artifactName);
+ }
+ if (log.isDebugEnabled()) {
+ log.debug("Template Undeployment of the template named : "
+ + artifactName + " : Completed");
+ }
+ log.info("Template named '" + st.getName() + "' has been undeployed");
+ } else {
+ TemplateMediator tm = getSynapseConfiguration().getSequenceTemplate(artifactName);
+ if (tm != null) {
+ getSynapseConfiguration().removeSequenceTemplate(artifactName);
+ if (log.isDebugEnabled()) {
+ log.debug("Destroying the Template named : " + artifactName);
+ }
+ tm.destroy();
+ if (log.isDebugEnabled()) {
+ log.debug("Template Undeployment of the template named : "
+ + artifactName + " : Completed");
+ }
+ log.info("Template named '" + st.getName() + "' has been undeployed");
+ } else {
+ log.debug("Template task " + artifactName + " has already been undeployed");
+ }
+ }
+ } catch (Exception e) {
+ handleSynapseArtifactDeploymentError(
+ "Template Undeployement of template named : " + artifactName + " : Failed", e);
+ }
+ }
+
+ @Override
+ public void restoreSynapseArtifact(String artifactName) {
+
+ if (log.isDebugEnabled()) {
+ log.debug("Restoring the Template with name : " + artifactName + " : Started");
+ }
+
+ try {
+ Template st = getSynapseConfiguration().getEndpointTemplate(artifactName);
+ if (st != null) {
+ TemplateSerializer ts = new TemplateSerializer();
+ OMElement stElem = ts.serializeEndpointTemplate(st, null);
+ if (st.getFileName() != null) {
+ String fileName = getServerConfigurationInformation().getSynapseXMLLocation()
+ + File.separator + MultiXMLConfigurationBuilder.TEMPLATES_DIR
+ + File.separator + st.getFileName();
+ writeToFile(stElem, fileName);
+ if (log.isDebugEnabled()) {
+ log.debug("Restoring the Endpoint Template with name : " +
+ artifactName + " : Completed");
+ }
+ log.info("Template named '" + artifactName + "' has been restored");
+ }
+ } else {
+ TemplateMediator mt = getSynapseConfiguration().getSequenceTemplate(artifactName);
+ if (mt != null) {
+ TemplateMediatorSerializer ts = new TemplateMediatorSerializer();
+ OMElement stElem = ts.serializeMediator(null, mt);
+ if (mt.getFileName() != null) {
+ String fileName = getServerConfigurationInformation().getSynapseXMLLocation()
+ + File.separator + MultiXMLConfigurationBuilder.TEMPLATES_DIR
+ + File.separator + st.getFileName();
+ writeToFile(stElem, fileName);
+ if (log.isDebugEnabled()) {
+ log.debug("Restoring the Sequence Template with name : " +
+ artifactName + " : Completed");
+ }
+ log.info("Template named '" + artifactName + "' has been restored");
+ }
+ } else {
+ handleSynapseArtifactDeploymentError("Couldn't restore the Template named '"
+ + artifactName + "', filename cannot be found");
+ }
+ }
+ } catch (Exception e) {
+ handleSynapseArtifactDeploymentError(
+ "Restoring of the Template named '" + artifactName + "' has failed", e);
+ }
+ }
+}
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/template/TemplateMediator.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/template/TemplateMediator.java?rev=1086160&r1=1086159&r2=1086160&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/template/TemplateMediator.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/template/TemplateMediator.java Mon Mar 28 09:09:20 2011
@@ -24,6 +24,7 @@ import org.apache.synapse.SynapseLog;
import org.apache.synapse.core.SynapseEnvironment;
import org.apache.synapse.mediators.AbstractListMediator;
+import javax.sound.midi.Sequence;
import java.util.Collection;
import java.util.Stack;
Modified: synapse/trunk/java/repository/conf/axis2.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/axis2.xml?rev=1086160&r1=1086159&r2=1086160&view=diff
==============================================================================
--- synapse/trunk/java/repository/conf/axis2.xml (original)
+++ synapse/trunk/java/repository/conf/axis2.xml Mon Mar 28 09:09:20 2011
@@ -89,6 +89,7 @@
<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"/>
<deployer extension="xml" directory="conf/synapse-config/priority-executors" class="org.apache.synapse.deployers.PriorityExecutorDeployer"/>
+ <deployer extension="xml" directory="conf/synapse-config/templates" class="org.apache.synapse.deployers.TemplateDeployer"/>
<!-- Following parameter will set the host name for the epr-->
<!--<parameter name="hostname" locked="true">myhost.com</parameter>-->