Package io.vertigo.orchestra.plugins.services.schedule.db

Class DbProcessSchedulerPlugin

java.lang.Object

io.vertigo.orchestra.plugins.services.schedule.db.DbProcessSchedulerPlugin

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin, io.vertigo.core.node.definition.DefinitionProvider, io.vertigo.core.node.definition.SimpleDefinitionProvider, ProcessSchedulerPlugin, ProcessScheduler

public class DbProcessSchedulerPlugin
extends Object
implements ProcessSchedulerPlugin, io.vertigo.core.node.component.Activeable, io.vertigo.core.node.definition.SimpleDefinitionProvider

Plugin de gestion de la planification.

Version:

$Id$

Author:

mlaroche.

Constructor Summary

Constructors

Constructor	Description
DbProcessSchedulerPlugin(ONodeManager nodeManager, VTransactionManager transactionManager, OrchestraDefinitionManager definitionManager, String nodeName, Optional<Integer> planningPeriodSecondsOpt, Optional<Integer> forecastDurationSecondsOpt)	Constructeur.

Method Summary

Modifier and Type	Method	Description
ProcessType	getHandledProcessType()	Retourne le type de processus géré par le plugin
List<? extends io.vertigo.core.node.definition.Definition>	provideDefinitions(io.vertigo.core.node.definition.DefinitionSpace definitionSpace)
void	scheduleAt(ProcessDefinition processDefinition, Instant planifiedTime, Map<String,String> initialParams)	Planifie un processus à une date donnée.
void	setProcessExecutor(ProcessExecutor processExecutor)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.vertigo.core.node.definition.DefinitionProvider

addDefinitionResourceConfig

Methods inherited from interface io.vertigo.core.node.definition.SimpleDefinitionProvider

get

Constructor Detail

DbProcessSchedulerPlugin

@Inject
public DbProcessSchedulerPlugin(ONodeManager nodeManager,
                                VTransactionManager transactionManager,
                                OrchestraDefinitionManager definitionManager,
                                String nodeName,
                                Optional<Integer> planningPeriodSecondsOpt,
                                Optional<Integer> forecastDurationSecondsOpt)

Constructeur.

Parameters:

nodeManager - le gestionnaire de noeud

transactionManager - vertigo transaction manager

definitionManager - orchestra definitions manager

nodeName - le nom du noeud

planningPeriodSecondsOpt - le timer de planfication (30 seconds by default)

forecastDurationSecondsOpt - la durée de prévision des planifications (3600 seconds by default)

Method Detail

provideDefinitions

public List<? extends io.vertigo.core.node.definition.Definition> provideDefinitions(io.vertigo.core.node.definition.DefinitionSpace definitionSpace)

Specified by:

provideDefinitions in interface io.vertigo.core.node.definition.SimpleDefinitionProvider

start

public void start()

Specified by:

start in interface io.vertigo.core.node.component.Activeable

setProcessExecutor

public void setProcessExecutor(ProcessExecutor processExecutor)

Specified by:

setProcessExecutor in interface ProcessSchedulerPlugin

stop

public void stop()

Specified by:

stop in interface io.vertigo.core.node.component.Activeable

getHandledProcessType

public ProcessType getHandledProcessType()

Description copied from interface: ProcessSchedulerPlugin

Retourne le type de processus géré par le plugin

Specified by:

getHandledProcessType in interface ProcessSchedulerPlugin

Returns:

le type de processus géré

scheduleAt

public void scheduleAt(ProcessDefinition processDefinition,
                       Instant planifiedTime,
                       Map<String,String> initialParams)

Description copied from interface: ProcessScheduler

Planifie un processus à une date donnée.

Specified by:

scheduleAt in interface ProcessScheduler

Parameters:

processDefinition - le processus à planifier

planifiedTime - la date de planification

initialParams - les paramètres initiaux à utiliser