消费者自动创建

c74223b1 · yanzg · 7d781458 · c74223b1
Commit c74223b1 authored Apr 15, 2019 by yanzg
Show whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

MessageServiceImpl.java ...a/com/yanzuoguang/mq/service/impl/MessageServiceImpl.java +3 -1

No files found.
--- a/yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MessageServiceImpl.java
+++ b/yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MessageServiceImpl.java
@@ -137,8 +137,10 @@ public class MessageServiceImpl implements MessageService {
        } else {
            MessageVo messageTo = messageDao.load(messageVo.getMessageId(), MessageVo.class);
            isEmpty = messageTo == null;
+            if(messageTo != null){
                messageVo = messageTo;
            }
+        }
        // 设置处理次数
        messageVo.setHandleCount(messageVo.getHandleCount() + 1);