message 동기화 async 처리

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) {

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();
 

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);