Browse Source

rabbitmq config 수정

feature/auth
노승철 2 years ago
parent
commit
0c0fd4fe0c
  1. 15
      src/main/java/com/palnet/biz/config/MessageConfig.java
  2. 2
      src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
  3. 5
      src/main/resources/application.yml

15
src/main/java/com/palnet/biz/config/MessageConfig.java

@ -24,7 +24,20 @@ public class MessageConfig {
@Bean @Bean
public CachingConnectionFactory cachingConnectionFactory() { public CachingConnectionFactory cachingConnectionFactory() {
return new CachingConnectionFactory(); CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
// log.info("profile : {}", env.getProperty("spring.config.activate.on-profile"));
//
// log.info("rabbitmq host : {}", env.getProperty("spring.rabbitmq.host"));
// log.info("rabbitmq port : {}", env.getProperty("spring.rabbitmq.port"));
// log.info("rabbitmq host : {}", env.getProperty("spring.rabbitmq.username"));
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 @Bean

2
src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java

@ -28,7 +28,7 @@ public class MessageConsumer {
} }
@RabbitHandler @RabbitHandler
@RabbitListener(queues = {"app.drone.queue"}, concurrency = "8") @RabbitListener(queues = {"app.drone.queue"})
public void receivedDroneMessage(final String message) { public void receivedDroneMessage(final String message) {
GPModel model = new GPModel(); GPModel model = new GPModel();

5
src/main/resources/application.yml

@ -160,10 +160,7 @@ spring:
port: 5672 port: 5672
username: palnet username: palnet
password: palnet1234 password: palnet1234
listener:
simple:
max-concurrency: 8
concurrency: 4
server: server:
port: 8080 port: 8080
servlet: servlet:

Loading…
Cancel
Save