浏览代码

Allow a job to cause broadcast to abort at time posting

Achieved by adding the isBroadcastFatal method to Job class.
tags/1.0.21
ymlam 2 年前
父节点
当前提交
44e771a8f6
共有 2 个文件被更改,包括 10 次插入0 次删除
  1. +1
    -0
      src/main/java/altk/comm/engine/Broadcast.java
  2. +9
    -0
      src/main/java/altk/comm/engine/Job.java

+ 1
- 0
src/main/java/altk/comm/engine/Broadcast.java 查看文件

@@ -1271,6 +1271,7 @@ public abstract class Broadcast
*/ */
public void postJobStatus(Job job) public void postJobStatus(Job job)
{ {
if (job.isBroadcastFatal()) setState(BroadcastState.ABORTING);
if (job.jobStatus == CommJobStatus.SUCCESS) successCount.incrementAndGet(); if (job.jobStatus == CommJobStatus.SUCCESS) successCount.incrementAndGet();
if (postback != null) if (postback != null)
{ {


+ 9
- 0
src/main/java/altk/comm/engine/Job.java 查看文件

@@ -74,4 +74,13 @@ public class Job
return errorText; return errorText;
} }


/**
*
* @return true to indicate that broadcast should abort.
*/
protected boolean isBroadcastFatal()
{
return false;
}

} }

正在加载...
取消
保存