Commit a3d0064a by huangfusuper

增加日志push开始节点

parent 3b9c2194
...@@ -88,7 +88,13 @@ public class MythJobProcess implements Callable<String>{ ...@@ -88,7 +88,13 @@ public class MythJobProcess implements Callable<String>{
@SneakyThrows @SneakyThrows
@Override @Override
public String call() { public String call() {
RunLog startRunLog = RunLog.builder().isEnd(false).runLog("start").build();
//stringRedisTemplate.convertAndSend(runKey, JSON.toJSONString(runLog, WriteClassName))
//TODO 向队尾追加一个日志
Long startLong = stringRedisTemplate.opsForList().rightPush(runKey , JSON.toJSONString(startRunLog, WriteClassName));
if(startLong <= 0){
log.error("------日志信息加入redis异常,{}---------",startLong);
}
//判断是否执行过 //判断是否执行过
if (this.isStarted() || this.isComplete()) { if (this.isStarted() || this.isComplete()) {
throw new IllegalStateException("该过程只能使用一次"); throw new IllegalStateException("该过程只能使用一次");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment