Package org.springframework.integration.zookeeper.leader

Class LeaderInitiator

java.lang.Object

org.springframework.integration.zookeeper.leader.LeaderInitiator

All Implemented Interfaces:

Lifecycle, Phased, SmartLifecycle

public class LeaderInitiator
extends Object
implements SmartLifecycle

Bootstrap leadership candidates with ZooKeeper/Curator. Upon construction, start() must be invoked to register the candidate for leadership election.

Since:

4.2

Author:

Patrick Peralta, Janne Valkealahti, Gary Russell, Artem Bilan, Ivan Zaitsev, Christian Tzolov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	LeaderInitiator.CuratorContext	Implementation of leadership context backed by Curator.
protected class	LeaderInitiator.LeaderListener	Implementation of Curator leadership election listener.

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
LeaderInitiator(org.apache.curator.framework.CuratorFramework client, Candidate candidate)	Construct a LeaderInitiator.
LeaderInitiator(org.apache.curator.framework.CuratorFramework client, Candidate candidate, String namespace)	Construct a LeaderInitiator.

Method Summary

Modifier and Type	Method	Description
LeaderInitiator.CuratorContext	getContext()	The context of the initiator.
int	getPhase()
boolean	isAutoStartup()
boolean	isRunning()
void	setAutoStartup(boolean autoStartup)
void	setLeaderEventPublisher(LeaderEventPublisher leaderEventPublisher)	Sets the LeaderEventPublisher.
void	setPhase(int phase)
void	start()	Start the registration of the candidate for leader election.
void	stop()	Stop the registration of the candidate for leader election.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.SmartLifecycle

stop

Constructor Details

LeaderInitiator

public LeaderInitiator(org.apache.curator.framework.CuratorFramework client,
 Candidate candidate)

Construct a LeaderInitiator.

Parameters:

client - Curator client

candidate - leadership election candidate

LeaderInitiator

public LeaderInitiator(org.apache.curator.framework.CuratorFramework client,
 Candidate candidate,
 String namespace)

Construct a LeaderInitiator.

Parameters:

client - Curator client

candidate - leadership election candidate

namespace - namespace base path in zookeeper

Method Details

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

Returns:

true if leadership election for this candidate is running

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

Specified by:

getPhase in interface SmartLifecycle

setPhase

public void setPhase(int phase)

Parameters:

phase - the phase

See Also:

• SmartLifecycle

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

setAutoStartup

public void setAutoStartup(boolean autoStartup)

Parameters:

autoStartup - true to start automatically

See Also:

• SmartLifecycle

start

public void start()

Start the registration of the candidate for leader election.

Specified by:

start in interface Lifecycle

stop

public void stop()

Stop the registration of the candidate for leader election. If the candidate is currently leader, its leadership will be revoked.

Specified by:

stop in interface Lifecycle

setLeaderEventPublisher

public void setLeaderEventPublisher(LeaderEventPublisher leaderEventPublisher)

Sets the LeaderEventPublisher.

Parameters:

leaderEventPublisher - the event publisher

getContext

public LeaderInitiator.CuratorContext getContext()

The context of the initiator.

Returns:

the context.

Since:

5.0