jiazx0107@163.com
2023-11-18 f15b4feb486a85dcc3b9b5c68a8526957a6ad0bd
src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java
@@ -84,12 +84,6 @@
            public void handleMessage(Message<?> message) throws MessagingException {
                String topic = message.getHeaders().get("mqtt_receivedTopic").toString();
                String msg = message.getPayload().toString();
                // 这里可以处理接收的数据
                log.info("----------------------------收到订阅内容---------------------------");
                log.info("-----TOPIC-----{}", topic);
                log.info("-----Message-----{}", msg);
                onReceiveMqttService.onReceiveMessage(topic, msg);
            }
        };