|
|
@@ -53,7 +53,7 @@ public class RabbitMqConfig {
|
|
|
private String host;
|
|
|
|
|
|
@Value("#{sys['spring.rabbitmq.port']}")
|
|
|
- private String port;
|
|
|
+ private int port;
|
|
|
|
|
|
@Value("#{sys['spring.rabbitmq.username']}")
|
|
|
private String username;
|
|
|
@@ -76,6 +76,7 @@ public class RabbitMqConfig {
|
|
|
public ConnectionFactory connectionFactory() {
|
|
|
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
|
|
|
connectionFactory.setAddresses(this.host);
|
|
|
+ connectionFactory.setPort(this.port);
|
|
|
connectionFactory.setUsername(this.username);
|
|
|
connectionFactory.setPassword(this.password);
|
|
|
connectionFactory.setVirtualHost(this.virtualHost);
|