diff --git a/src/main/java/com/palnet/process/message/config/MessageConfig.java b/src/main/java/com/palnet/process/message/config/MessageConfig.java index 299acf0..bcb6eca 100644 --- a/src/main/java/com/palnet/process/message/config/MessageConfig.java +++ b/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 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 137bd46..48b4a76 100644 --- a/src/main/java/com/palnet/process/message/consumer/MessageConsumer.java +++ b/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); diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 6d87f86..e3e4955 100644 --- a/src/main/resources/application.yml +++ b/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 diff --git a/src/test/java/com/palnet/PavWebsocketApplicationTests.java b/src/test/java/com/palnet/PavWebsocketApplicationTests.java deleted file mode 100644 index 1878032..0000000 --- a/src/test/java/com/palnet/PavWebsocketApplicationTests.java +++ /dev/null @@ -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() { - } - -}