jiazx0107@163.com
2024-01-19 6a9cf62f7ca4b45c48a571c63fd484c186070a0e
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);
            }
        };