|
@@ -12,8 +12,6 @@ import java.util.List;
|
|
@Service
|
|
@Service
|
|
public class RabbitMqService {
|
|
public class RabbitMqService {
|
|
|
|
|
|
- @Value("${spring.rabbitmq.host}")
|
|
|
|
- public String host;
|
|
|
|
@Value("${spring.rabbitmq.username}")
|
|
@Value("${spring.rabbitmq.username}")
|
|
public String username;
|
|
public String username;
|
|
@Value("${spring.rabbitmq.password}")
|
|
@Value("${spring.rabbitmq.password}")
|
|
@@ -22,11 +20,10 @@ public class RabbitMqService {
|
|
public String virtualHost;
|
|
public String virtualHost;
|
|
@Value("${spring.rabbitmq.mgmt-url}")
|
|
@Value("${spring.rabbitmq.mgmt-url}")
|
|
public String mgmtUrl;
|
|
public String mgmtUrl;
|
|
- @Value("${spring.rabbitmq.mgmt-host}")
|
|
|
|
- public String mgmtHost;
|
|
|
|
|
|
+
|
|
|
|
|
|
public MqMsg getRabbitMqMsg(String queueName) {
|
|
public MqMsg getRabbitMqMsg(String queueName) {
|
|
- return RabbitMqUtils.getRabbitMqMsg(mgmtUrl+host+":"+mgmtHost,virtualHost,username,password,queueName);
|
|
|
|
|
|
+ return RabbitMqUtils.getRabbitMqMsg(mgmtUrl,virtualHost,username,password,queueName);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|