remove listeners from unit discovery

Signed-off-by: Roie Geron <roie.geron@gmail.com>
openhab · May 14, 2022 · a423715 · a423715
1 parent 6c2363d
commit a423715
Showing 1 changed file with 1 addition and 24 deletions.
diff --git a/.../java/org/openhab/binding/touchwand/internal/discovery/TouchWandUnitDiscoveryService.java b/.../java/org/openhab/binding/touchwand/internal/discovery/TouchWandUnitDiscoveryService.java
@@ -18,15 +18,13 @@
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.concurrent.CopyOnWriteArraySet;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
 
 import org.eclipse.jdt.annotation.NonNull;
 import org.eclipse.jdt.annotation.NonNullByDefault;
 import org.eclipse.jdt.annotation.Nullable;
 import org.openhab.binding.touchwand.internal.TouchWandBridgeHandler;
-import org.openhab.binding.touchwand.internal.TouchWandUnitStatusUpdateListener;
 import org.openhab.binding.touchwand.internal.dto.TouchWandUnitData;
 import org.openhab.binding.touchwand.internal.dto.TouchWandUnitFromJson;
 import org.openhab.core.config.discovery.AbstractDiscoveryService;
@@ -60,8 +58,7 @@ public class TouchWandUnitDiscoveryService extends AbstractDiscoveryService impl
     private @NonNullByDefault({}) TouchWandBridgeHandler touchWandBridgeHandler;
     private final Logger logger = LoggerFactory.getLogger(TouchWandUnitDiscoveryService.class);
 
-    private @Nullable ScheduledFuture<?> scanningJob;
-    private CopyOnWriteArraySet<TouchWandUnitStatusUpdateListener> listeners = new CopyOnWriteArraySet<>();
+    private @Nullable ScheduledFuture<?> scanningJob;    
 
     public TouchWandUnitDiscoveryService() {
         super(SUPPORTED_THING_TYPES_UIDS, SEARCH_TIME_SEC, true);
@@ -123,7 +120,6 @@ protected void startScan() {
                             default:
                                 continue;
                         }
-                        notifyListeners(touchWandUnit);
                     }
                 } catch (JsonSyntaxException e) {
                     logger.warn("Could not parse unit {}", e.getMessage());
@@ -134,12 +130,6 @@ protected void startScan() {
         }
     }
 
-    private void notifyListeners(TouchWandUnitData touchWandUnit) {
-        for (TouchWandUnitStatusUpdateListener listener : listeners) {
-            listener.onDataReceived(touchWandUnit);
-        }
-    }
-
     @Override
     protected void stopScan() {
         removeOlderResults(getTimestampOfLastScan());
@@ -176,18 +166,6 @@ protected void stopBackgroundDiscovery() {
         }
     }
 
-    public void registerListener(TouchWandUnitStatusUpdateListener listener) {
-        if (!listeners.contains(listener)) {
-            logger.debug("Adding TouchWandWebSocket listener {}", listener);
-            listeners.add(listener);
-        }
-    }
-
-    public void unregisterListener(TouchWandUnitStatusUpdateListener listener) {
-        logger.debug("Removing TouchWandWebSocket listener {}", listener);
-        listeners.remove(listener);
-    }
-
     @Override
     public int getScanTimeout() {
         return SEARCH_TIME_SEC;
@@ -215,7 +193,6 @@ private void addDeviceDiscoveryResult(TouchWandUnitData unit, ThingTypeUID typeU
     public void setThingHandler(@NonNullByDefault({}) ThingHandler handler) {
         if (handler instanceof TouchWandBridgeHandler) {
             touchWandBridgeHandler = (TouchWandBridgeHandler) handler;
-            registerListener(touchWandBridgeHandler);
         }
     }