MasterNodeCronScheduler.java

package com.wix.cronulla.example;

import com.wix.cronulla.example.GetTasks;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter;

import java.util.concurrent.ExecutorService;

public class LeaderNodeCronScheduler extends LeaderSelectorListenerAdapter {

    public LeaderNodeCronScheduler(GetTasks getTasks, ExecutorService executorService) { }

    @Override
    public void takeLeadership(CuratorFramework curatorFramework) throws Exception {
        try {
            while (true) {
                if (Thread.currentThread().isInterrupted()) {
                    throw new InterruptedException();
                }
                // process currently available scheduled tasks (getTasks) to run on a separate thread pool (executorService)
                // delay next iteration
            }
        } catch (InterruptedException ex) {

        } finally {
            // Stop processing scheduling tasks
        }
    }
}