From 35166d575c235960c96e184651ceaf6337a35a51 Mon Sep 17 00:00:00 2001
From: fanqq <fanqq@ctrip.com>
Date: Mon, 19 Sep 2016 10:40:34 +0800
Subject: [PATCH] fix logger

---
 .../service/message/queue/impl/MessageQueueServiceImpl.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/main/java/com/ctrip/zeus/service/message/queue/impl/MessageQueueServiceImpl.java b/src/main/java/com/ctrip/zeus/service/message/queue/impl/MessageQueueServiceImpl.java
index 7a4c7ace..137af096 100644
--- a/src/main/java/com/ctrip/zeus/service/message/queue/impl/MessageQueueServiceImpl.java
+++ b/src/main/java/com/ctrip/zeus/service/message/queue/impl/MessageQueueServiceImpl.java
@@ -63,10 +63,10 @@ public class MessageQueueServiceImpl implements MessageQueueService {
     }
 
     public void fetchMessage() throws Exception {
-        logger.info("[MessageQueueService] Start Fetch Messages. StartTime:" + startTime.toString());
         Map<String, List<Message>> res = new HashMap<>();
         List<MessageQueueDo> list = messageQueueDao.findByStatusAndAfterCreateTime("TODO", startTime, MessageQueueEntity.READSET_FULL);
         if (list != null && list.size() > 0) {
+            logger.info("[MessageQueueService] Fetch Messages success. StartTime:" + startTime.toString() + ";count:" + list.size());
             for (MessageQueueDo messageQueueDo : list) {
                 if (!res.containsKey(messageQueueDo.getType())) {
                     res.put(messageQueueDo.getType(), new ArrayList<Message>());
@@ -85,8 +85,6 @@ public class MessageQueueServiceImpl implements MessageQueueService {
             }
 
             logger.info("[MessageQueueService] Finish Fetch Messages. message count:" + list.size());
-        } else {
-            logger.info("[MessageQueueService] Finish Fetch Messages. Not Found Any Message.");
         }
     }