diff --git a/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/InsteonLegacyBinding.java b/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/InsteonLegacyBinding.java index fc1ae270b7515..12d2fa990e317 100644 --- a/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/InsteonLegacyBinding.java +++ b/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/InsteonLegacyBinding.java @@ -517,7 +517,7 @@ public void disconnected() { private void handleInsteonMessage(Msg msg) throws FieldException { InsteonAddress toAddr = msg.getInsteonAddress("toAddress"); - if (!msg.isBroadcast() && !driver.isMsgForUs(toAddr)) { + if (!msg.isBroadcast() && !msg.isAllLinkBroadcast() && !driver.isMsgForUs(toAddr)) { // not for one of our modems, do not process return; } diff --git a/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/device/LegacyDevice.java b/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/device/LegacyDevice.java index 4d7db0357b335..1d2af57fe03d8 100644 --- a/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/device/LegacyDevice.java +++ b/bundles/org.openhab.binding.insteon/src/main/java/org/openhab/binding/insteon/internal/device/LegacyDevice.java @@ -336,7 +336,7 @@ public long processRequestQueue(long timeNow) { if (qe == null) { return 0L; } - if (!qe.getMsg().isBroadcast()) { + if (!qe.getMsg().isAllLinkBroadcast()) { logger.debug("qe taken off direct: {} {}", qe.getFeature(), qe.getMsg()); lastQueryTime = timeNow; // mark feature as pending @@ -384,7 +384,7 @@ public void enqueueDelayedMessage(Msg msg, LegacyDeviceFeature feature, long del synchronized (mrequestQueue) { mrequestQueue.add(new QEntry(feature, msg, now + delay)); } - if (!msg.isBroadcast()) { + if (!msg.isAllLinkBroadcast()) { msg.setQuietTime(QUIET_TIME_DIRECT_MESSAGE); } logger.trace("enqueing direct message with delay {}", delay);