Authored by jack.xue

fix rabbitmq port

... ... @@ -60,4 +60,6 @@ public interface InterVar {
int MONIT_TIMEOUT = 10;
String RETENTION_POLICY = "default";
String port = "15672";
}
... ...
... ... @@ -37,7 +37,7 @@ public class RabbitMonitTask {
@Autowired
RabbitAlertMapper rabbitAlertMapper;
@Scheduled(cron = "0 0/1 * * * ? ")
@Scheduled(cron = "0 0/3 * * * ? ")
public void doTask() {
//加载所有的alert
List<RabbitAlertInfo> alertInfos = rabbitAlertMapper.getAllAlertsInfo();
... ...
... ... @@ -33,7 +33,7 @@ public class ClusterViewJob implements Callable {
public void doTask() {
MObjectInfo moInfo = InterVar.moMaps.get(moId);
String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), moInfo.getMoTags()) + InterVar.NODES_URL;
String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.NODES_URL;
if (null == moInfo) {
... ...
... ... @@ -38,7 +38,7 @@ public class OverViewJob implements Callable {
public void doTask() {
MObjectInfo moInfo = InterVar.moMaps.get(moId);
String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), moInfo.getMoTags()) + InterVar.OVERVIEW_URL;
String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.OVERVIEW_URL;
if (null == moInfo) {
... ...
... ... @@ -39,7 +39,7 @@ public class QueueViewJob implements Callable {
public void doTask() {
MObjectInfo moInfo = InterVar.moMaps.get(moId);
String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), moInfo.getMoTags()) + InterVar.QUEUE_URL;
String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.QUEUE_URL;
if (null == moInfo) {
... ...