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) {
