|
|
@@ -238,10 +238,6 @@ public class MqttCore {
|
|
|
if (getClient().isConnected()) {
|
|
|
// 如果此mqtt已经建立了连接,则正常订阅
|
|
|
for (String topic : topics) {
|
|
|
- if(topic.contains("qxz")){
|
|
|
- //TODO://暂时屏蔽气象站相关设备
|
|
|
- continue;
|
|
|
- }
|
|
|
getClient().subscribe(topic);
|
|
|
log.info("[MQTT] {} 连接已建立 追加订阅主题 {}", cfgYf.getDeviceType(), topic);
|
|
|
}
|