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 Details

    • DbProcessSchedulerPlugin

      @Inject public DbProcessSchedulerPlugin(ONodeManager nodeManager, io.vertigo.commons.transaction.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 Details

    • 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