海康电表维护

doum

2026-03-30 1879eaa3af5e45c6228ec2188a6c324000b3d7fa

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/mqtt/MqttSubServiceImpl.java

@@ -17,7 +17,7 @@
@Slf4j
public class MqttSubServiceImpl implements MqttBizService {
    @Autowired
    private MqttPushCallback callBack ;
    private MqttPushCallback callBack;
    @Override
    public MqttClient subscribe(MqttClient client,MqttConfig config,String[] topics){
        log.error("mqtt订阅开始========开始"+ JSONObject.toJSONString(config));
@@ -32,7 +32,6 @@
        log.error("mqtt订阅开始========结束"+ JSONObject.toJSONString(config));
        return client;
    }

    @Override
    public MqttClient publish(MqttClient client,MqttConfig config, String topic, String param){
        log.error("mqtt发布消息========开始"+ JSONObject.toJSONString(config)+"\n"+param);