Skip to content

Commit 585e456

Browse files
If applied, this commit will fix send device.
1 parent e2c5345 commit 585e456

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/main/java/dlt/load/balancer/model/Balancer.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -140,9 +140,11 @@ public void sendDevice(Device device, String targetIp, String targetMqttPort) th
140140
jsonPublish.addProperty("port", targetMqttPort);
141141
jsonPublish.addProperty("user", "karaf");
142142
jsonPublish.addProperty("password", "karaf");
143-
143+
144+
String topic = "dev/"+device.getId();
145+
144146
iPublisher.publish(
145-
device.getId(),
147+
topic,
146148
"SET VALUE brokerMqtt{" + jsonPublish.toString() + "}"
147149
);
148150

0 commit comments

Comments
 (0)