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<BasicMessageDto> 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 처리한 카운트에 대한 처리