From acb499d11849ef2eb5dcba60f556d0de921ed372 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: Wed, 10 Aug 2022 16:50:24 +0900
Subject: [PATCH] =?UTF-8?q?message=20=EB=8F=99=EA=B8=B0=ED=99=94=20async?=
 =?UTF-8?q?=20=EC=B2=98=EB=A6=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/palnet/Application.java                       | 2 ++
 .../java/com/palnet/biz/message/consumer/MessageConsumer.java   | 2 +-
 .../com/palnet/biz/message/service/impl/MessageServiceImpl.java | 2 ++
 3 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/palnet/Application.java b/src/main/java/com/palnet/Application.java
index 81922b0..7bcd1db 100644
--- a/src/main/java/com/palnet/Application.java
+++ b/src/main/java/com/palnet/Application.java
@@ -4,10 +4,12 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.Bean;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableScheduling
+@EnableAsync
 public class Application {
 
 	public static void main(String[] args) {
diff --git a/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java b/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
index fdd6032..15aa4b4 100644
--- a/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
+++ b/src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
@@ -28,7 +28,7 @@ public class MessageConsumer {
     }
 
     @RabbitHandler
-    @RabbitListener(queues = {"app.drone.queue"})
+    @RabbitListener(queues = {"app.drone.queue"}, concurrency = "8")
     public void receivedDroneMessage(final String message) {
         GPModel model = new GPModel();
 
diff --git a/src/main/java/com/palnet/biz/message/service/impl/MessageServiceImpl.java b/src/main/java/com/palnet/biz/message/service/impl/MessageServiceImpl.java
index 33408a7..546c92d 100644
--- a/src/main/java/com/palnet/biz/message/service/impl/MessageServiceImpl.java
+++ b/src/main/java/com/palnet/biz/message/service/impl/MessageServiceImpl.java
@@ -20,6 +20,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.BeanUtils;
 import org.springframework.core.env.Environment;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -98,6 +99,7 @@ public class MessageServiceImpl implements MessageService {
 
     @Override
     @Transactional
+    @Async
     public void insert(GPModel model) {
         GPDatabaseModel dbModel = new GPDatabaseModel();
         BeanUtils.copyProperties(model, dbModel);