org.apache.shardingsphere.elasticjob.lite.api.listener

Class AbstractDistributeOnceElasticJobListener

java.lang.Object

org.apache.shardingsphere.elasticjob.lite.api.listener.AbstractDistributeOnceElasticJobListener

All Implemented Interfaces:

ElasticJobListener, TypedSPI

public abstract class AbstractDistributeOnceElasticJobListener
extends Object
implements ElasticJobListener

Distributed once elasticjob listener.

Field Summary

Fields inherited from interface org.apache.shardingsphere.elasticjob.infra.listener.ElasticJobListener

LOWEST

Constructor Summary

Constructors

Constructor and Description
AbstractDistributeOnceElasticJobListener(long startedTimeoutMilliseconds, long completedTimeoutMilliseconds)

Method Summary

Modifier and Type	Method and Description
void	afterJobExecuted(ShardingContexts shardingContexts)
void	beforeJobExecuted(ShardingContexts shardingContexts)
abstract void	doAfterJobExecutedAtLastCompleted(ShardingContexts shardingContexts) Do after job executed at last sharding job completed.
abstract void	doBeforeJobExecutedAtLastStarted(ShardingContexts shardingContexts) Do before job executed at last sharding job started.
void	notifyWaitingTaskComplete() Notify waiting task complete.
void	notifyWaitingTaskStart() Notify waiting task start.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.shardingsphere.elasticjob.infra.listener.ElasticJobListener

order

Methods inherited from interface org.apache.shardingsphere.elasticjob.infra.spi.TypedSPI

getType

Constructor Detail

AbstractDistributeOnceElasticJobListener

public AbstractDistributeOnceElasticJobListener(long startedTimeoutMilliseconds,
                                                long completedTimeoutMilliseconds)

Method Detail

beforeJobExecuted

public final void beforeJobExecuted(ShardingContexts shardingContexts)

Specified by:

beforeJobExecuted in interface ElasticJobListener

afterJobExecuted

public final void afterJobExecuted(ShardingContexts shardingContexts)

Specified by:

afterJobExecuted in interface ElasticJobListener

doBeforeJobExecutedAtLastStarted

public abstract void doBeforeJobExecutedAtLastStarted(ShardingContexts shardingContexts)

Do before job executed at last sharding job started.

Parameters:

shardingContexts - sharding contexts

doAfterJobExecutedAtLastCompleted

public abstract void doAfterJobExecutedAtLastCompleted(ShardingContexts shardingContexts)

Do after job executed at last sharding job completed.

Parameters:

shardingContexts - sharding contexts

notifyWaitingTaskStart

public void notifyWaitingTaskStart()

Notify waiting task start.

notifyWaitingTaskComplete

public void notifyWaitingTaskComplete()

Notify waiting task complete.