src/main/java/com/dji/sample/component/mqtt/handler/InboundMessageRouter.java
@@ -45,7 +45,7 @@ String topic = headers.get(MqttHeaders.RECEIVED_TOPIC).toString(); byte[] payload = (byte[])message.getPayload(); log.debug("received topic :{} \t payload :{}", topic, new String(payload)); // log.debug("received topic :{} \t payload :{}", topic, new String(payload)); DeviceTopicEnum topicEnum = DeviceTopicEnum.find(topic); MessageChannel bean = (MessageChannel) SpringBeanUtils.getBean(topicEnum.getBeanName());