```

feat(mqtt): 修改消息发送方法返回类型为Boolean - 将MqttMessageSender.sendMessage方法的返回类型从void改为Boolean - 添加成功时返回result，失败时返回false的逻辑 - 同步更新MqttMessageService接口中的方法签名 - 增强消息发送结果的可追踪性 ```

```
feat(mqtt): 修改消息发送方法返回类型为Boolean - 将MqttMessageSender.sendMessage方法的返回类型从void改为Boolean - 添加成功时返回result，失败时返回false的逻辑 - 同步更新MqttMessageService接口中的方法签名 - 增强消息发送结果的可追踪性 ```
zhangmeiyang
1 parent 59358ca8
Showing 2 changed files with 4 additions and 2 deletions
mqtt-core/src/main/java/com/diligrp/mqtt/core/service/MqttMessageService.java
mqtt-integration/src/main/java/com/diligrp/mqtt/integration/handler/MqttMessageSender.java
@@ -9,5 +9,5 @@ public interface MqttMessageService {
      *
      * @param sendModel 发送模型
      */
-    void sendMessage(SendModel sendModel);
+    Boolean sendMessage(SendModel sendModel);
 }
@@ -35,7 +35,7 @@ public class MqttMessageSender implements MqttMessageService {
     private ApplicationEventPublisher applicationEventPublisher;
  
     @Override
-    public void sendMessage(SendModel sendModel) {
+    public Boolean sendMessage(SendModel sendModel) {
         Optional.ofNullable(sendModel).orElseThrow(()->new MqttServiceException("消息结构体不能为空"));
         Optional.ofNullable(sendModel.getTopic()).filter(e -> !e.isEmpty()).orElseThrow(()->new MqttServiceException("【消息主题】不能为空"));
         Optional.ofNullable(sendModel.getPayload()).orElseThrow(()->new MqttServiceException("【消息内容】不能为空"));
@@ -60,9 +60,11 @@ public class MqttMessageSender implements MqttMessageService {
                 log.error("消息发送失败 - :{}", JsonUtils.toJsonString(message));
                 applicationEventPublisher.publishEvent(new SendFailEvent(this, sendModel));
             });
+            return result;
         } catch (Exception e) {
             log.error("发送Mqtt消息失败", e);
             applicationEventPublisher.publishEvent(new SendFailEvent(this, sendModel));
         }
+        return false;
     }
 }