|
|
|
@@ -55,7 +55,7 @@ public class MqttMessageHandle implements IMqttMessageHandler { |
|
|
|
public void getMqttTopicService(Message<?> message){ |
|
|
|
// 在这里 我们根据不同的 主题 分发不同的消息 |
|
|
|
String receivedTopic = message.getHeaders().get("mqtt_receivedTopic",String.class); |
|
|
|
log.info("receivedTopic="+receivedTopic + " message="+message.getPayload()); |
|
|
|
log.info("receivedTopic = {},message = {}", receivedTopic ,message.getPayload()); |
|
|
|
if(receivedTopic==null || "".equals(receivedTopic)){ |
|
|
|
return; |
|
|
|
} |
|
|
|
|