com.dangdang.ddframe.job.api.listener

类 AbstractDistributeOnceElasticJobListener

java.lang.Object

com.dangdang.ddframe.job.api.listener.AbstractDistributeOnceElasticJobListener

所有已实现的接口:

ElasticJobListener

public abstract class AbstractDistributeOnceElasticJobListener
extends Object
implements ElasticJobListener

在分布式作业中只执行一次的监听器.

作者:

zhangliang

构造器概要

构造器

构造器和说明
AbstractDistributeOnceElasticJobListener(long startedTimeoutMilliseconds, long completedTimeoutMilliseconds)

方法概要

方法

限定符和类型	方法和说明
void	afterJobExecuted(JobExecutionMultipleShardingContext shardingContext) 作业执行后的执行的方法.
void	beforeJobExecuted(JobExecutionMultipleShardingContext shardingContext) 作业执行前的执行的方法.
abstract void	doAfterJobExecutedAtLastCompleted(JobExecutionMultipleShardingContext shardingContext) 分布式环境中最后一个作业执行后的执行的方法.
abstract void	doBeforeJobExecutedAtLastStarted(JobExecutionMultipleShardingContext shardingContext) 分布式环境中最后一个作业执行前的执行的方法.
void	notifyWaitingTaskComplete() 通知任务结束.
void	notifyWaitingTaskStart() 通知任务开始.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

AbstractDistributeOnceElasticJobListener

public AbstractDistributeOnceElasticJobListener(long startedTimeoutMilliseconds,
                                        long completedTimeoutMilliseconds)

方法详细资料

beforeJobExecuted

public final void beforeJobExecuted(JobExecutionMultipleShardingContext shardingContext)

从接口复制的说明: ElasticJobListener

作业执行前的执行的方法.

指定者:

beforeJobExecuted 在接口中 ElasticJobListener

参数:

shardingContext - 分片上下文

afterJobExecuted

public final void afterJobExecuted(JobExecutionMultipleShardingContext shardingContext)

从接口复制的说明: ElasticJobListener

作业执行后的执行的方法.

指定者:

afterJobExecuted 在接口中 ElasticJobListener

参数:

shardingContext - 分片上下文

doBeforeJobExecutedAtLastStarted

public abstract void doBeforeJobExecutedAtLastStarted(JobExecutionMultipleShardingContext shardingContext)

分布式环境中最后一个作业执行前的执行的方法.

参数:

shardingContext - 分片上下文

doAfterJobExecutedAtLastCompleted

public abstract void doAfterJobExecutedAtLastCompleted(JobExecutionMultipleShardingContext shardingContext)

分布式环境中最后一个作业执行后的执行的方法.

参数:

shardingContext - 分片上下文

notifyWaitingTaskStart

public void notifyWaitingTaskStart()

通知任务开始.

notifyWaitingTaskComplete

public void notifyWaitingTaskComplete()

通知任务结束.