From 9ea4d7653bc69ca15576be06d56ff7be462ffc8a Mon Sep 17 00:00:00 2001 From: jangdongsin Date: Thu, 9 Jan 2025 00:04:26 +0900 Subject: [PATCH] =?UTF-8?q?=ED=81=90=20=EC=A1=B0=ED=9A=8C=20=EC=A0=81?= =?UTF-8?q?=EC=9E=AC=20=EB=A1=9C=EC=A7=81=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/service/QueueServerService.java | 31 +++++++++++-------- 1 file changed, 18 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/munjaon/server/server/service/QueueServerService.java b/src/main/java/com/munjaon/server/server/service/QueueServerService.java index b1c53c8..3de8e60 100644 --- a/src/main/java/com/munjaon/server/server/service/QueueServerService.java +++ b/src/main/java/com/munjaon/server/server/service/QueueServerService.java @@ -195,20 +195,25 @@ public class QueueServerService extends Service { private void messageService() throws Exception { int DB_PROC_COUNT = 0; List list = new ArrayList<>(); - for (int loopCnt = 0; loopCnt < ServiceUtil.COMMIT_COUNT; loopCnt++) { - BasicMessageDto messageDto = readQueue.popMessageFromBuffer(); - if (messageDto == null) { - break; + /* 큐 메시지 조회 */ + try { + for (int loopCnt = 0; loopCnt < ServiceUtil.COMMIT_COUNT; loopCnt++) { + BasicMessageDto messageDto = readQueue.popMessageFromBuffer(); + if (messageDto == null) { + break; + } + /* MSG ID 채번 */ + String msgId = queueInstance.getSerialNumber(); + msgId = MessageUtil.makeMessageKey(msgId); + String msgGroupId = msgId.replace("MSGID", "MGRP"); + messageDto.setId(msgId); + messageDto.setMsgGroupID(msgGroupId); + list.add(messageDto); + DB_PROC_COUNT++; + SUM_COMMIT_COUNT++; } - /* MSG ID 채번 */ - String msgId = queueInstance.getSerialNumber(); - msgId = MessageUtil.makeMessageKey(msgId); - String msgGroupId = msgId.replace("MSGID", "MGRP"); - messageDto.setId(msgId); - messageDto.setMsgGroupID(msgGroupId); - list.add(messageDto); - DB_PROC_COUNT++; - SUM_COMMIT_COUNT++; + } catch (Exception e) { + saveLog(e); } // DB 처리한 카운트에 대한 처리