Skip to content
Snippets Groups Projects
Commit 7c51a3eb authored by René Schöne's avatar René Schöne
Browse files

Small fix to not update non-changed state when receiving MQTT message.

parent d564e65b
Branches
Tags 0.1
No related merge requests found
......@@ -57,10 +57,13 @@ public class MQTTUpdater implements AutoCloseable {
}
private void itemUpdate(Item item, String state) {
String oldState = item.getStateAsString();
if (oldState == null || !oldState.equals(state)) {
this.logger.debug("Update state of {} [{}] from '{}' to '{}'.",
item.getLabel(), item.getID(), item.getStateAsString(), state);
item.getLabel(), item.getID(), oldState, state);
item.setStateFromString(state, false);
}
}
/**
* Waits until this updater is ready to receive MQTT messages.
......
package de.tudresden.inf.st.eraser.util;
import de.tudresden.inf.st.eraser.openhab2.mqtt.MQTTUpdater;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.fusesource.hawtbuf.Buffer;
......@@ -40,7 +39,7 @@ public class MqttReceiver implements AutoCloseable {
private QoS qos;
public MqttReceiver() {
this.logger = LogManager.getLogger(MQTTUpdater.class);
this.logger = LogManager.getLogger(MqttReceiver.class);
this.readyLock = new ReentrantLock();
this.readyCondition = readyLock.newCondition();
this.ready = false;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment