We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a491825 commit 81a93cfCopy full SHA for 81a93cf
1 file changed
app/src/main/java/com/path/variable/mqtt/pub/demo/App.java
@@ -25,12 +25,11 @@ public void run() {
25
}
26
final var publisher = new MqttPublisher(mqttCfg.addr(), mqttCfg.clientId());
27
while (true) {
28
- var map = new LinkedHashMap<String, Number>();
+ var reportMap = new LinkedHashMap<String, Number>();
29
for (var sensor : sensors) {
30
- map.put(sensor.label(), sensor.nextValue());
+ reportMap.put(sensor.label(), sensor.nextValue());
31
32
- var report = new RoomReport(map);
33
- publisher.publish(report, mqttCfg.topic());
+ publisher.publish(reportMap, mqttCfg.topic());
34
try {
35
sleep(mqttCfg.intervalMs() != null ? mqttCfg.intervalMs() : 1000);
36
} catch (InterruptedException e) {
0 commit comments