com.broadleafcommerce.jobsevents.service

Interface ScheduledDeployManager

All Known Implementing Classes:

ScheduledDeployManagerImpl

public interface ScheduledDeployManager

Responsible for processing SystemEvent instances of type . There is only ever one active ScheduledJobManager in the cluster (the master). If the current master fails, another node may become active (master/slave HA config).

Author:

Jeff Fischer

Method Summary

Modifier and Type	Method and Description
void	activate(boolean enabled)
Map<String,SystemEventFactory>	getEventFactories() Retrieve the list of factories responsible for creating SystemEvent instances upon job execution.
DatabaseSystemEventNode	getEventNode() This ScheduledJobManager instance is also a node in the cluster.
long	getJobThreadPoolCount() The number of Quartz thread available for jobs execution.
long	getMasterNodeHeartbeatIntervalSeconds() The amount of time between each heartbeat update for this node, if active.
long	getNodePurgeIntervalSeconds() The amount of time between each master purge attempt.
long	getNodePurgeThresholdSeconds() The amount of time an active master is allowed to not update it's heartbeat status before being a purge candidate.
org.quartz.Scheduler	getScheduler() Retrieve the internal Quartz scheduler instance.
boolean	isMaster()
boolean	isMaster(boolean confirmStillMasterNode) Verifies that the current eventNode is the masterDeployNode by retrieving the node designated as master and double checking.
boolean	isPause() Whether this node is paused.
void	reset() Programatically remove this node from master/active status.
void	setEventFactories(Map<String,SystemEventFactory> eventFactories)
void	setEventNode(DatabaseSystemEventNode eventNode)
void	setJobThreadPoolCount(long jobThreadPoolCount)
void	setMaster(boolean master)
void	setMasterNodeHeartbeatIntervalSeconds(long masterNodeHeartbeatInterval)
void	setNodePurgeIntervalSeconds(long masterNodePurgeInterval)
void	setNodePurgeThresholdSeconds(long masterNodePurgeThreshold)
void	setPause(boolean pause)
void	stop()

Method Detail

stop

void stop()

getMasterNodeHeartbeatIntervalSeconds

long getMasterNodeHeartbeatIntervalSeconds()

The amount of time between each heartbeat update for this node, if active. Default is 10.

Returns:

setMasterNodeHeartbeatIntervalSeconds

void setMasterNodeHeartbeatIntervalSeconds(long masterNodeHeartbeatInterval)

getNodePurgeThresholdSeconds

long getNodePurgeThresholdSeconds()

The amount of time an active master is allowed to not update it's heartbeat status before being a purge candidate. The default is 60.

Returns:

setNodePurgeThresholdSeconds

void setNodePurgeThresholdSeconds(long masterNodePurgeThreshold)

getNodePurgeIntervalSeconds

long getNodePurgeIntervalSeconds()

The amount of time between each master purge attempt. The default is 30.

Returns:

setNodePurgeIntervalSeconds

void setNodePurgeIntervalSeconds(long masterNodePurgeInterval)

isPause

boolean isPause()

Whether this node is paused. A paused manager will not update job status and the internal Quartz instances are also paused, resulting in registered jobs not firing.

Returns:

setPause

void setPause(boolean pause)

getJobThreadPoolCount

long getJobThreadPoolCount()

The number of Quartz thread available for jobs execution. The default is 20.

Returns:

setJobThreadPoolCount

void setJobThreadPoolCount(long jobThreadPoolCount)

reset

void reset()

Programatically remove this node from master/active status. This should only be called during a shutdown.

isMaster

boolean isMaster()

isMaster

boolean isMaster(boolean confirmStillMasterNode)

Verifies that the current eventNode is the masterDeployNode by retrieving the node designated as master and double checking. If the node was marked as the master and confirmed to not be the master, the master is reset via the setMaster() method.

Parameters:

confirm -

Returns:

setMaster

void setMaster(boolean master)

activate

void activate(boolean enabled)

getEventFactories

Map<String,SystemEventFactory> getEventFactories()

Retrieve the list of factories responsible for creating SystemEvent instances upon job execution. Jobs, when fired, result in events. Event are then consumed, which is the end goal.

Returns:

setEventFactories

void setEventFactories(Map<String,SystemEventFactory> eventFactories)

getScheduler

org.quartz.Scheduler getScheduler()

Retrieve the internal Quartz scheduler instance.

Returns:

getEventNode

DatabaseSystemEventNode getEventNode()

This ScheduledJobManager instance is also a node in the cluster. Retrieve the associated DatabaseSystemEventNode instance.

Returns:

setEventNode

void setEventNode(DatabaseSystemEventNode eventNode)