Package org.opencastproject.lifecyclemanagement.impl

Class LifeCycleTaskRunner

java.lang.Object
org.opencastproject.lifecyclemanagement.impl.LifeCycleTaskRunner
public class LifeCycleTaskRunner extends Object
Periodically checks on the tasks in the database. If there are scheduled tasks this attempts to run them. If there are running tasks this attempts to check if their status should be changed

  • Field Details

    • lifeCycleService

      protected org.opencastproject.lifecyclemanagement.api.LifeCycleService lifeCycleService

    • workflowService

      protected org.opencastproject.workflow.api.WorkflowService workflowService

    • assetManager

      protected org.opencastproject.assetmanager.api.AssetManager assetManager

    • securityService

      protected org.opencastproject.security.api.SecurityService securityService

    • organizationDirectoryService

      protected org.opencastproject.security.api.OrganizationDirectoryService organizationDirectoryService

    • scheduledExecutor

      protected ScheduledExecutorService scheduledExecutor
      The thread pool to use for dispatching queued jobs and checking on phantom services.

  • Constructor Details

    • LifeCycleTaskRunner

      public LifeCycleTaskRunner()

  • Method Details

    • setLifeCycleService

      public void setLifeCycleService(org.opencastproject.lifecyclemanagement.api.LifeCycleService lifeCycleService)

    • setWorkflowService

      public void setWorkflowService(org.opencastproject.workflow.api.WorkflowService workflowService)

    • setAssetManager

      public void setAssetManager(org.opencastproject.assetmanager.api.AssetManager assetManager)

    • setSecurityService

      public void setSecurityService(org.opencastproject.security.api.SecurityService securityService)

    • setOrganizationDirectoryService

      public void setOrganizationDirectoryService(org.opencastproject.security.api.OrganizationDirectoryService orgDirServ)

    • setIndexService

      public void setIndexService(org.opencastproject.index.service.api.IndexService indexService)

    • activate

      public void activate(org.osgi.service.component.ComponentContext cc) throws org.osgi.service.cm.ConfigurationException
      Throws:
      org.osgi.service.cm.ConfigurationException

    • modified

      public void modified(org.osgi.service.component.ComponentContext cc) throws org.osgi.service.cm.ConfigurationException
      Throws:
      org.osgi.service.cm.ConfigurationException

    • updated

      public void updated(Dictionary<String,?> properties) throws org.osgi.service.cm.ConfigurationException
      Throws:
      org.osgi.service.cm.ConfigurationException

    • deactivate

      public void deactivate()