public class MyDistributeOnceJobListener extends AbstractDistributeOnceElasticJobListener {
    public TestDistributeOnceElasticJobListener(long startTimeoutMills, long completeTimeoutMills) {
        super(startTimeoutMills, completeTimeoutMills);
    public void doBeforeJobExecutedAtLastStarted(ShardingContexts shardingContexts) {
        // do something ...
    }
    @Override
    }
    @Override
    public String getType() {
        return "distributeOnceJobListener";
    }