You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ra...@apache.org on 2016/06/05 05:49:39 UTC

svn commit: r1746863 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints: AbstractEndpoint.java EndpointView.java

Author: ravi
Date: Sun Jun  5 05:49:39 2016
New Revision: 1746863

URL: http://svn.apache.org/viewvc?rev=1746863&view=rev
Log:
Fix for SYNAPSE-1003

Modified:
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointView.java

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java?rev=1746863&r1=1746862&r2=1746863&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/AbstractEndpoint.java Sun Jun  5 05:49:39 2016
@@ -585,9 +585,14 @@ public abstract class AbstractEndpoint e
     }
 
     public void destroy() {
+        if (metricsMBean != null) {
+            metricsMBean.destroy();
+        }
+
         if (enableMBeanStats) {
             MBeanRegistrar.getInstance().unRegisterMBean("Endpoint", endpointName);
         }
+        metricsMBean = null;
         this.initialized = false;
     }
 

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointView.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointView.java?rev=1746863&r1=1746862&r2=1746863&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointView.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/endpoints/EndpointView.java Sun Jun  5 05:49:39 2016
@@ -114,6 +114,8 @@ public class EndpointView implements End
 
     public void destroy() {
         future.cancel(true);
+        suspensionCounts.clear();
+        timeoutCounts.clear();
     }
 
     // --- endpoint control ---