jiazx0107@163.com
2023-12-07 9b5c86d852fd94c0f01497d7571b27419ab17c58
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);
            }
        };