You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by hi...@apache.org on 2011/02/07 14:28:42 UTC
svn commit: r1067945 -
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/EndpointDeployer.java
Author: hiranya
Date: Mon Feb 7 13:28:42 2011
New Revision: 1067945
URL: http://svn.apache.org/viewvc?rev=1067945&view=rev
Log:
Registering the endpoint MBean on hot updates
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/EndpointDeployer.java
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/EndpointDeployer.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/EndpointDeployer.java?rev=1067945&r1=1067944&r2=1067945&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/EndpointDeployer.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/deployers/EndpointDeployer.java Mon Feb 7 13:28:42 2011
@@ -23,6 +23,7 @@ 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.commons.jmx.MBeanRegistrar;
import org.apache.synapse.config.xml.MultiXMLConfigurationBuilder;
import org.apache.synapse.config.xml.endpoints.EndpointFactory;
import org.apache.synapse.config.xml.endpoints.EndpointSerializer;
@@ -116,6 +117,12 @@ public class EndpointDeployer extends Ab
sleep(2000);
existingEp.destroy();
+ if (existingArtifactName.equals(ep.getName())) {
+ // If the endpoint name was same as the old one, above method call (destroy)
+ // will unregister the endpoint MBean - So we should register it again.
+ MBeanRegistrar.getInstance().registerMBean(
+ ep.getMetricsMBean(), "Endpoint", ep.getName());
+ }
return ep.getName();
} catch (DeploymentException e) {