yinruoxi

添加：
    1.框架变更：mqtt新增保留消息功能

xueyi-common/xueyi-common-mqtt/src/main/java/com/xueyi/common/mqtt/configure/MqttConfigV2.java

@@ -76,6 +76,7 @@ public class MqttConfigV2 {
         handler.setAsync(true);
         handler.setConverter(new DefaultPahoMessageConverter());
         handler.setDefaultTopic(mqttProperties.getDefaultTopic().split(",")[0]);
+        handler.setDefaultRetained(false);
         return IntegrationFlows.from( "mqttOutboundChannel").handle(handler).get();
     }
 }

xueyi-common/xueyi-common-mqtt/src/main/java/com/xueyi/common/mqtt/connection/MqttTemplate.java

@@ -19,4 +19,6 @@ public interface MqttTemplate {
     void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, String data);
 
     void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) Integer Qos, String data);
+
+    void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.RETAINED) Boolean retained, String data);
 }