You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by am...@apache.org on 2013/05/29 14:29:04 UTC

svn commit: r1487453 - /cxf/dosgi/trunk/discovery/distributed/cxf-discovery/src/main/java/org/apache/cxf/dosgi/discovery/zookeeper/InterfaceMonitorManager.java

Author: amichai
Date: Wed May 29 12:29:04 2013
New Revision: 1487453

URL: http://svn.apache.org/r1487453
Log:
DOSGI-173 Change creation of InterfaceMonitor to occur only once per scope

Modified:
    cxf/dosgi/trunk/discovery/distributed/cxf-discovery/src/main/java/org/apache/cxf/dosgi/discovery/zookeeper/InterfaceMonitorManager.java

Modified: cxf/dosgi/trunk/discovery/distributed/cxf-discovery/src/main/java/org/apache/cxf/dosgi/discovery/zookeeper/InterfaceMonitorManager.java
URL: http://svn.apache.org/viewvc/cxf/dosgi/trunk/discovery/distributed/cxf-discovery/src/main/java/org/apache/cxf/dosgi/discovery/zookeeper/InterfaceMonitorManager.java?rev=1487453&r1=1487452&r2=1487453&view=diff
==============================================================================
--- cxf/dosgi/trunk/discovery/distributed/cxf-discovery/src/main/java/org/apache/cxf/dosgi/discovery/zookeeper/InterfaceMonitorManager.java (original)
+++ cxf/dosgi/trunk/discovery/distributed/cxf-discovery/src/main/java/org/apache/cxf/dosgi/discovery/zookeeper/InterfaceMonitorManager.java Wed May 29 12:29:04 2013
@@ -75,15 +75,10 @@ public class InterfaceMonitorManager {
                     interest.relatedServiceListeners.add(sref);
                 }
 
-                if (interest.im != null) {
-                    // close old InterfaceMonitor
-                    interest.im.close();
-                    interest.im = null;
-                }
-                
-                InterfaceMonitor dm = createInterfaceMonitor(scope, objClass, interest);
-                dm.start();
-                interest.im = dm;
+                if (interest.im == null) {
+                    interest.im = createInterfaceMonitor(scope, objClass, interest);
+                    interest.im.start();
+                }
 
                 List<String> handledScopes = handledEndpointlisteners.get(sref);
                 if (handledScopes == null) {