|
|
@@ -33,10 +33,6 @@ public class MqttPublisher {
|
|
|
public void publish(String topic, String message) throws MqttException {
|
|
|
CompletableFuture.runAsync(() -> {
|
|
|
try {
|
|
|
- if(topic.contains("qxz")){
|
|
|
- //TODO://暂时屏蔽气象站相关设备
|
|
|
- return;
|
|
|
- }
|
|
|
log.info("发MQTT消息,topic:{},message:{}",topic,message);
|
|
|
mqttClient.publish(topic, message.getBytes(), 0, false);
|
|
|
}catch (Exception e){
|