diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/CenterQueue.java b/o2server/x_program_center/src/main/java/com/x/program/center/CenterQueue.java index 307b11a4d61dd740c79cb0f63f89e1ba0cf38261..6499161ac175dd6ab97d06e4a17c57f18745285c 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/CenterQueue.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/CenterQueue.java @@ -20,7 +20,8 @@ public class CenterQueue extends AbstractQueue { private static Logger logger = LoggerFactory.getLogger(CenterQueue.class); - public static final int REFRESHAPPLICATIONSINTERVAL = 45; + //public static final int REFRESHAPPLICATIONSINTERVAL = 45; + public static final int REFRESHAPPLICATIONSINTERVAL = 30; protected void execute(CenterQueueBody body) throws Exception { diff --git a/o2server/x_program_center/src/main/java/com/x/program/center/schedule/RefreshApplications.java b/o2server/x_program_center/src/main/java/com/x/program/center/schedule/RefreshApplications.java index 965907951c537d684f413b57dd782cfddaebfabe..a9a10a9eb460ee3f276884e8b07d29597b7fd861 100644 --- a/o2server/x_program_center/src/main/java/com/x/program/center/schedule/RefreshApplications.java +++ b/o2server/x_program_center/src/main/java/com/x/program/center/schedule/RefreshApplications.java @@ -15,10 +15,8 @@ public class RefreshApplications extends BaseAction { @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { try { - if (pirmaryCenter()) { - CenterQueueRefreshBody body = new CenterQueueRefreshBody(); - ThisApplication.centerQueue.send(body); - } + CenterQueueRefreshBody body = new CenterQueueRefreshBody(); + ThisApplication.centerQueue.send(body); } catch (Exception e) { logger.error(e); throw new JobExecutionException(e);