From 49011fd6f69092d87a85a39a598946654cea04be Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?scnoh=28=EB=85=B8=EC=8A=B9=EC=B2=A0=29?=
 <stc9606@palnet.co.kr>
Date: Thu, 22 Sep 2022 13:58:50 +0900
Subject: [PATCH] message consumer thread add

---
 .../com/palnet/process/message/consumer/MessageConsumer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java
index 3f81170..ee7aafa 100644
--- a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java
+++ b/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java
@@ -39,7 +39,7 @@ public class MessageConsumer {
 	}
 
     @RabbitHandler
-    @RabbitListener(queues = {"websocket.drone.queue"})
+    @RabbitListener(queues = {"websocket.drone.queue"}, concurrency = "8")
     public void receiveDroneMessage(final String message) throws JsonProcessingException {
 		log.info("websocket message : {}", message);
 		GPModel model = objectMapper.readValue(message, GPModel.class);