Skip to content

Commit af86e08

Browse files
committed
Disable watchdog integration until linked channels are properly tracked.
Signed-off-by: Łukasz Dywicki <[email protected]>
1 parent 209452b commit af86e08

File tree

1 file changed

+3
-3
lines changed
  • bundles/org.connectorio.addons.binding.bacnet/src/main/java/org/connectorio/addons/binding/bacnet/internal/handler/object

1 file changed

+3
-3
lines changed

bundles/org.connectorio.addons.binding.bacnet/src/main/java/org/connectorio/addons/binding/bacnet/internal/handler/object/BACnetDeviceHandler.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ public void initialize() {
138138
}
139139

140140
protected void initializeChannels(BacNetClient client) {
141-
WatchdogBuilder watchdogBuilder = watchdogManager.builder(getThing());
141+
//WatchdogBuilder watchdogBuilder = watchdogManager.builder(getThing());
142142

143143
DeviceConfig deviceConfig = getConfigAs(DeviceConfig.class);
144144
discoverObjects = deviceConfig.discoverObjects;
@@ -152,7 +152,7 @@ protected void initializeChannels(BacNetClient client) {
152152
Long refreshInterval = Optional.ofNullable(deviceChannelConfig.refreshInterval)
153153
.filter(value -> value != 0)
154154
.orElse(getRefreshInterval());
155-
watchdogBuilder.withChannel(channel.getUID(), refreshInterval);
155+
//watchdogBuilder.withChannel(channel.getUID(), refreshInterval);
156156
if (!pollingMap.containsKey(refreshInterval)) {
157157
pollingMap.put(refreshInterval, new LinkedHashSet<>());
158158
}
@@ -173,7 +173,7 @@ public void run() {
173173
}
174174
}, 0, 30, TimeUnit.SECONDS);
175175

176-
this.watchdog = watchdogBuilder.build(getCallback(), new ThingStatusWatchdogListener(getThing(), getCallback()));
176+
//this.watchdog = watchdogBuilder.build(getCallback(), new ThingStatusWatchdogListener(getThing(), getCallback()));
177177
for (Entry<Long, Set<Readout>> entry : pollingMap.entrySet()) {
178178
ScheduledFuture<?> poller = scheduler.scheduleAtFixedRate(new RefreshDeviceTask(() -> clientFuture, watchdog.getCallbackWrapper(), device, entry.getValue(), linkedChannels),
179179
0, entry.getKey(), TimeUnit.MILLISECONDS);

0 commit comments

Comments
 (0)