public/openhab-addons
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[digitalstrom] fix NPE (#8992)

Browse Source 
* fix NPE
* fix formatting

Signed-off-by: Jan N. Klug <jan.n.klug@rub.de>
This commit is contained in:
J-N-K 2020-11-10 08:43:13 +01:00 committed by GitHub
parent 132f05bba5
commit c0118930be
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
bundles/org.openhab.binding.digitalstrom/src/main/java/org/openhab/binding/digitalstrom/internal/lib/event/EventListener.java
View File

@ -14,7 +14,6 @@ package org.openhab.binding.digitalstrom.internal.lib.event;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.ScheduledExecutorService;
@ -137,14 +136,21 @@ public class EventListener {
return isStarted;
}
private void internalStop() {
if (subscriptionScheduler != null && !subscriptionScheduler.isCancelled()) {
private void stopSubscriptionScheduler() {
final ScheduledFuture<?> subscriptionScheduler = this.subscriptionScheduler;
if (subscriptionScheduler != null) {
subscriptionScheduler.cancel(true);
subscriptionScheduler = null;
this.subscriptionScheduler = null;
}
if (pollingScheduler != null && !pollingScheduler.isCancelled()) {
}
private void internalStop() {
stopSubscriptionScheduler();
ScheduledFuture<?> pollingScheduler = this.pollingScheduler;
if (pollingScheduler != null) {
pollingScheduler.cancel(true);
pollingScheduler = null;
this.pollingScheduler = null;
unsubscribe();
logger.debug("internal stop EventListener");
}
@ -347,17 +353,10 @@ public class EventListener {
return subscribed;
}
private void subscribe(final List<String> evetNames) {
final Iterator<String> eventNameIter = evetNames.iterator();
subscriptionScheduler = scheduler.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
while (eventNameIter.hasNext()) {
subscribe(eventNameIter.next());
}
subscriptionScheduler.cancel(true);
}
private void subscribe(final List<String> eventNames) {
subscriptionScheduler = scheduler.scheduleWithFixedDelay(() -> {
eventNames.forEach(this::subscribe);
stopSubscriptionScheduler();
}, 0, SUBSCRIBE_DELAY, TimeUnit.MILLISECONDS);
}