提交 89b5b819 编写于 作者: Z zhourui

删除其他的cleanup

上级 bd8e84c4
...@@ -22,7 +22,7 @@ public class Cleanup extends BaseAction { ...@@ -22,7 +22,7 @@ public class Cleanup extends BaseAction {
private List<Class<? extends JpaObject>> list = new ArrayList<>(); private List<Class<? extends JpaObject>> list = new ArrayList<>();
private int tag = 0; private volatile int tag = 0;
public Cleanup() { public Cleanup() {
list.add(ScheduleLog.class); list.add(ScheduleLog.class);
...@@ -35,7 +35,8 @@ public class Cleanup extends BaseAction { ...@@ -35,7 +35,8 @@ public class Cleanup extends BaseAction {
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
try { try {
if (pirmaryCenter()) { if (pirmaryCenter()) {
ThisApplication.logQueue.send(new NameValuePair(list.get((tag++) % list.size()).getName(), null)); ThisApplication.logQueue.send(new NameValuePair(list.get(tag).getName(), null));
tag = (tag + 1) % list.size();
} }
} catch (Exception e) { } catch (Exception e) {
logger.error(e); logger.error(e);
......
package com.x.program.center.schedule;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.x.base.core.project.bean.NameValuePair;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
import com.x.program.center.ThisApplication;
import com.x.program.center.core.entity.PromptErrorLog;
public class CleanupPromptErrorLog extends BaseAction {
private static Logger logger = LoggerFactory.getLogger(CleanupPromptErrorLog.class);
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
try {
if (pirmaryCenter()) {
ThisApplication.logQueue.send(new NameValuePair(PromptErrorLog.class.getName(), null));
}
} catch (Exception e) {
logger.error(e);
throw new JobExecutionException(e);
}
}
}
package com.x.program.center.schedule;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.x.base.core.project.bean.NameValuePair;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
import com.x.program.center.ThisApplication;
import com.x.program.center.core.entity.UnexpectedErrorLog;
public class CleanupUnexpectedErrorLog extends BaseAction {
private static Logger logger = LoggerFactory.getLogger(CleanupUnexpectedErrorLog.class);
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
try {
if (pirmaryCenter()) {
ThisApplication.logQueue.send(new NameValuePair(UnexpectedErrorLog.class.getName(), null));
}
} catch (Exception e) {
logger.error(e);
throw new JobExecutionException(e);
}
}
}
package com.x.program.center.schedule;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.x.base.core.project.bean.NameValuePair;
import com.x.base.core.project.logger.Logger;
import com.x.base.core.project.logger.LoggerFactory;
import com.x.program.center.ThisApplication;
import com.x.program.center.core.entity.WarnLog;
public class CleanupWarnLog extends BaseAction {
private static Logger logger = LoggerFactory.getLogger(CleanupWarnLog.class);
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
try {
if (pirmaryCenter()) {
ThisApplication.logQueue.send(new NameValuePair(WarnLog.class.getName(), null));
}
} catch (Exception e) {
logger.error(e);
throw new JobExecutionException(e);
}
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册