Showing
1 changed file
with
2 additions
and
2 deletions
| @@ -184,7 +184,7 @@ public class CzDeviceReportService { | @@ -184,7 +184,7 @@ public class CzDeviceReportService { | ||
| 184 | 184 | ||
| 185 | try { | 185 | try { |
| 186 | log.debug("开始MQTT发布: deviceId={}", deviceId); | 186 | log.debug("开始MQTT发布: deviceId={}", deviceId); |
| 187 | - MqttUtils.quickPublish(broker, topic, username, password, clientId, JSON.toJSONString(deviceMap)); | 187 | + MqttUtils.publish(broker, topic, username, password, clientId, JSON.toJSONString(deviceMap)); |
| 188 | successCount++; | 188 | successCount++; |
| 189 | 189 | ||
| 190 | // 每10个设备记录一次进度 | 190 | // 每10个设备记录一次进度 |
| @@ -318,4 +318,4 @@ public class CzDeviceReportService { | @@ -318,4 +318,4 @@ public class CzDeviceReportService { | ||
| 318 | log.info("数据库操作完成,返回{}条记录", resultList.size()); | 318 | log.info("数据库操作完成,返回{}条记录", resultList.size()); |
| 319 | return resultList; | 319 | return resultList; |
| 320 | } | 320 | } |
| 321 | -} | ||
| 321 | +} |