ctripcorp/zeus
1
1
Fork 0
mirror of https://github.com/ctripcorp/zeus.git synced 2024-09-20 15:46:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix logger

Browse source
This commit is contained in:
fanqq 2016-09-19 10:40:34 +08:00
parent 6ce3f5c173
commit 35166d575c
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/com/ctrip/zeus/service/message/queue/impl/MessageQueueServiceImpl.java
View file

@ -63,10 +63,10 @@ public class MessageQueueServiceImpl implements MessageQueueService {
} }
public void fetchMessage() throws Exception { public void fetchMessage() throws Exception {
logger.info("[MessageQueueService] Start Fetch Messages. StartTime:" + startTime.toString());
Map<String, List<Message>> res = new HashMap<>(); Map<String, List<Message>> res = new HashMap<>();
List<MessageQueueDo> list = messageQueueDao.findByStatusAndAfterCreateTime("TODO", startTime, MessageQueueEntity.READSET_FULL); List<MessageQueueDo> list = messageQueueDao.findByStatusAndAfterCreateTime("TODO", startTime, MessageQueueEntity.READSET_FULL);
if (list != null && list.size() > 0) { if (list != null && list.size() > 0) {
logger.info("[MessageQueueService] Fetch Messages success. StartTime:" + startTime.toString() + ";count:" + list.size());
for (MessageQueueDo messageQueueDo : list) { for (MessageQueueDo messageQueueDo : list) {
if (!res.containsKey(messageQueueDo.getType())) { if (!res.containsKey(messageQueueDo.getType())) {
res.put(messageQueueDo.getType(), new ArrayList<Message>()); 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()); logger.info("[MessageQueueService] Finish Fetch Messages. message count:" + list.size());
} else {
logger.info("[MessageQueueService] Finish Fetch Messages. Not Found Any Message.");
} }
} }