rabbitmq config 수정

src/main/java/com/palnet/process/message/config/MessageConfig.java

@@ -16,9 +16,22 @@ import org.springframework.core.env.Environment;
 @Configuration
 @Slf4j
 public class MessageConfig {
+
+    private final Environment env;
+
+    public MessageConfig(Environment env) {
+        this.env = env;
+    }
     @Bean
     public CachingConnectionFactory cachingConnectionFactory() {
-        return new CachingConnectionFactory();
+        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
+
+        connectionFactory.setHost(env.getProperty("spring.rabbitmq.host"));
+        connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port")));
+        connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username"));
+        connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password"));
+
+        return connectionFactory;
     }
 
     @Bean

src/main/java/com/palnet/process/message/consumer/MessageConsumer.java

@@ -28,8 +28,9 @@ public class MessageConsumer {
 	}
 
     @RabbitHandler
-    @RabbitListener(queues = {"websocket.drone.queue"}, concurrency = "8")
+    @RabbitListener(queues = {"websocket.drone.queue"})
     public void receiveDroneMessage(final String message) throws JsonProcessingException {
+		log.info("websocket message : {}", message);
 
 		GPModel model = objectMapper.readValue(message, GPModel.class);
 

src/main/resources/application.yml

@@ -42,10 +42,6 @@ spring:
     port: 5672
     username: palnet
     password: palnet1234
-    listener:
-      simple:
-        max-concurrency: 8
-        concurrency: 4
 
 server:
   port: 8181

src/test/java/com/palnet/PavWebsocketApplicationTests.java

@@ -1,13 +0,0 @@
-package com.palnet;
-
-import org.junit.jupiter.api.Test;
-import org.springframework.boot.test.context.SpringBootTest;
-
-@SpringBootTest
-class PavWebsocketApplicationTests {
-
-	@Test
-	void contextLoads() {
-	}
-
-}