Bug 3875: Removing listeners from SensorFixStore if there is no active

mapping for a given DeviceIdentifier anymore
This commit is contained in:
Steffen Schaefer committed 2016-08-15 17:12:34 +02:00
1 parent 8406ac762b
commit 9c837eaf10
5 files changed
+31 -4

No files matched your search

@@ -193,9 +193,12 @@ public class MongoSensorFixStoreImpl implements MongoSensorFixStore {
@Override
public synchronized void removeListener(FixReceivedListener<? extends Timed> listener) {
for (Set<FixReceivedListener<? extends Timed>> set : listeners.values()) {
set.remove(listener);
}
Util.removeFromAllValueSets(listeners, listener);
}
@Override
public synchronized void removeListener(FixReceivedListener<? extends Timed> listener, DeviceIdentifier device) {
Util.removeFromValueSet(listeners, device, listener);
}
private DBObject getDeviceQuery(DeviceIdentifier device)