|
|
@ -23,7 +23,14 @@ public class MessageConfig { |
|
|
|
|
|
|
|
|
|
|
|
@Bean |
|
|
|
@Bean |
|
|
|
public CachingConnectionFactory cachingConnectionFactory() { |
|
|
|
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 |
|
|
|
@Bean |
|
|
|