org.springframework.integration.support

Class SmartLifecycleRoleController

java.lang.Object

org.springframework.integration.support.SmartLifecycleRoleController

All Implemented Interfaces:

EventListener, Aware, ApplicationContextAware, ApplicationListener<AbstractLeaderEvent>

public class SmartLifecycleRoleController
extends Object
implements ApplicationListener<AbstractLeaderEvent>, ApplicationContextAware

Bulk start/stop SmartLifecycle in a particular role in phase order.

Since:

4.2

Author:

Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
SmartLifecycleRoleController(List<String> roles, List<SmartLifecycle> lifecycles) Construct an instance with the provided lists of roles and lifecycles, which must be of equal length.
SmartLifecycleRoleController(MultiValueMap<String,SmartLifecycle> lifecycles) Construct an instance with the provided map of roles/instances.

Method Summary

Modifier and Type	Method and Description
void	addLifecyclesToRole(String role, List<String> lifecycleBeanNames) Add a SmartLifecycle beans to the role using their names.
void	addLifecycleToRole(String role, SmartLifecycle lifecycle) Add a SmartLifecycle to the role.
void	addLifecycleToRole(String role, String lifecycleBeanName) Add a SmartLifecycle bean to the role using its name.
boolean	allEndpointsRunning(String role) Return true if all endpoints in the role are running.
Map<String,Boolean>	getEndpointsRunningStatus(String role) Return the running status of each endpoint in the role.
Collection<String>	getRoles() Return a collection of the roles currently managed by this controller.
boolean	noEndpointsRunning(String role) Return true if none of the endpoints in the role are running or if there are no endpoints in the role.
void	onApplicationEvent(AbstractLeaderEvent event)
boolean	removeLifecycle(SmartLifecycle lifecycle) Remove the provided SmartLifecycle from all the roles, for example when a SmartLifecycle bean is destroyed.
void	setApplicationContext(ApplicationContext applicationContext)
void	startLifecyclesInRole(String role) Start all registered SmartLifecycles in the role.
void	stopLifecyclesInRole(String role) Stop all registered SmartLifecycles in the role.

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.ApplicationListener

forPayload

Constructor Detail

SmartLifecycleRoleController

public SmartLifecycleRoleController(List<String> roles,
                                    List<SmartLifecycle> lifecycles)

Construct an instance with the provided lists of roles and lifecycles, which must be of equal length.

Parameters:

roles - the roles.

lifecycles - the lifecycles corresponding to the roles.

SmartLifecycleRoleController

public SmartLifecycleRoleController(MultiValueMap<String,SmartLifecycle> lifecycles)

Construct an instance with the provided map of roles/instances.

Parameters:

lifecycles - the MultiValueMap of beans in roles.

Method Detail

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

addLifecycleToRole

public final void addLifecycleToRole(String role,
                                     SmartLifecycle lifecycle)

Add a SmartLifecycle to the role.

Parameters:

role - the role.

lifecycle - the SmartLifecycle.

addLifecycleToRole

public final void addLifecycleToRole(String role,
                                     String lifecycleBeanName)

Add a SmartLifecycle bean to the role using its name.

Parameters:

role - the role.

lifecycleBeanName - the bean name of the SmartLifecycle.

addLifecyclesToRole

public void addLifecyclesToRole(String role,
                                List<String> lifecycleBeanNames)

Add a SmartLifecycle beans to the role using their names.

Parameters:

role - the role.

lifecycleBeanNames - the bean names of the SmartLifecycles.

startLifecyclesInRole

public void startLifecyclesInRole(String role)

Start all registered SmartLifecycles in the role.

Parameters:

role - the role.

stopLifecyclesInRole

public void stopLifecyclesInRole(String role)

Stop all registered SmartLifecycles in the role.

Parameters:

role - the role.

getRoles

public Collection<String> getRoles()

Return a collection of the roles currently managed by this controller.

Returns:

the roles.

Since:

4.3.8

allEndpointsRunning

public boolean allEndpointsRunning(String role)

Return true if all endpoints in the role are running.

Parameters:

role - the role.

Returns:

true if at least one endpoint in the role, and all are running.

Since:

4.3.8

noEndpointsRunning

public boolean noEndpointsRunning(String role)

Return true if none of the endpoints in the role are running or if there are no endpoints in the role.

Parameters:

role - the role.

Returns:

true if there are no endpoints or none are running.

Since:

4.3.8

getEndpointsRunningStatus

public Map<String,Boolean> getEndpointsRunningStatus(String role)

Return the running status of each endpoint in the role.

Parameters:

role - the role.

Returns:

A map of component names : running status

Since:

4.3.8

onApplicationEvent

public void onApplicationEvent(AbstractLeaderEvent event)

Specified by:

onApplicationEvent in interface ApplicationListener<AbstractLeaderEvent>

removeLifecycle

public boolean removeLifecycle(SmartLifecycle lifecycle)

Remove the provided SmartLifecycle from all the roles, for example when a SmartLifecycle bean is destroyed. The role entry in the lifecycles map is cleared as well if its value list is empty after SmartLifecycle removal.

Parameters:

lifecycle - the SmartLifecycle to remove.

Returns:

the removal status

Since:

5.0