com.netflix.genie.web.tasks.leader

Class LeadershipTasksCoordinator

java.lang.Object

com.netflix.genie.web.tasks.leader.LeadershipTasksCoordinator

public class LeadershipTasksCoordinator
extends java.lang.Object

Class which handles coordinating leadership related tasks. Listens for leadership grant and revoke events and starts tasks associated with being the cluster leader.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
LeadershipTasksCoordinator(org.springframework.scheduling.TaskScheduler taskScheduler, java.util.Collection<LeadershipTask> tasks) Constructor.

Method Summary

Modifier and Type	Method and Description
void	onLeaderEvent(org.springframework.integration.leader.event.AbstractLeaderEvent leaderEvent) Leadership event listener.
void	preDestroy() Make sure any threads are taken care of before this object is destroyed.

Methods inherited from class java.lang.Object

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

Constructor Detail

LeadershipTasksCoordinator

public LeadershipTasksCoordinator(org.springframework.scheduling.TaskScheduler taskScheduler,
                                  java.util.Collection<LeadershipTask> tasks)

Constructor.

Parameters:

taskScheduler - The task executor to use.

tasks - The leadership tasks to run

Method Detail

preDestroy

@PreDestroy
public void preDestroy()

Make sure any threads are taken care of before this object is destroyed.

onLeaderEvent

@EventListener
public void onLeaderEvent(org.springframework.integration.leader.event.AbstractLeaderEvent leaderEvent)

Leadership event listener. Starts and stop processes when this Genie node is elected the leader of the cluster.

Synchronized to ensure no race conditions between threads trying to start and stop leadership tasks.

Parameters:

leaderEvent - The leader grant or revoke event

See Also:

OnGrantedEvent, OnRevokedEvent