接口文档的支持

8ff25687 · yanzg · 3a4efb73 · 8ff25687
Commit 8ff25687 authored May 11, 2020 by yanzg
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 2 deletions

MqServiceImpl.java ...n/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java +5 -2

No files found.
--- a/yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java
+++ b/yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java
@@ -207,8 +207,11 @@ public class MqServiceImpl implements MqService {
        vo.setServerId(serverId);
        vo.setQueueName(queueName);
        vo.setQueueServer(localQueueName);
-        queueServerDao.create(vo);
-
+        if (queueServerTokenDao.load(vo, QueueServerVo.class) == null) {
+            queueServerDao.create(vo);
+        } else {
+            queueServerDao.update(vo);
+        }
        return "创建成功";
    }