Package org.opencastproject.scheduler.impl

Class SchedulerServiceImpl

java.lang.Object
org.opencastproject.elasticsearch.index.rebuild.AbstractIndexProducer
org.opencastproject.scheduler.impl.SchedulerServiceImpl
All Implemented Interfaces:
org.opencastproject.elasticsearch.index.rebuild.IndexProducer, org.opencastproject.scheduler.api.SchedulerService, org.osgi.service.cm.ManagedService
public class SchedulerServiceImpl extends org.opencastproject.elasticsearch.index.rebuild.AbstractIndexProducer implements org.opencastproject.scheduler.api.SchedulerService, org.osgi.service.cm.ManagedService
Implementation of SchedulerService.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected com.google.common.cache.Cache<String,String>
    lastModifiedCache
    The last modified cache

    Fields inherited from interface org.opencastproject.scheduler.api.SchedulerService

    JOB_TYPE, WORKFLOW_CONFIG_PREFIX

  • Constructor Summary

    Constructors
    Constructor
    Description
    SchedulerServiceImpl()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    activate(org.osgi.service.component.ComponentContext cc)
    Activates Scheduler Service.
    void
    addCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)
    OSGi callback to add EventCatalogUIAdapter instance.
    void
    addEvent(Date startDateTime, Date endDateTime, String captureAgentId, Set<String> userIds, org.opencastproject.mediapackage.MediaPackage mediaPackage, Map<String,String> wfProperties, Map<String,String> caMetadata, com.entwinemedia.fn.data.Opt<String> schedulingSource)
     
    Map<String,net.fortuna.ical4j.model.Period>
    addMultipleEvents(net.fortuna.ical4j.model.property.RRule rRule, Date start, Date end, Long duration, TimeZone tz, String captureAgentId, Set<String> userIds, org.opencastproject.mediapackage.MediaPackage templateMp, Map<String,String> wfProperties, Map<String,String> caMetadata, com.entwinemedia.fn.data.Opt<String> schedulingSource)
     
    void
    addSchedulerUpdateHandler(org.opencastproject.message.broker.api.update.SchedulerUpdateHandler handler)
    OSGi callback to add an update handler.
    List<org.opencastproject.mediapackage.MediaPackage>
    findConflictingEvents(String captureDeviceID, Date startDate, Date endDate)
     
    List<org.opencastproject.mediapackage.MediaPackage>
    findConflictingEvents(String captureAgentId, net.fortuna.ical4j.model.property.RRule rrule, Date start, Date end, long duration, TimeZone tz)
     
    String
    getCalendar(com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<String> seriesId, com.entwinemedia.fn.data.Opt<Date> cutoff)
     
    Map<String,String>
    getCaptureAgentConfiguration(String mediaPackageId)
     
    com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage>
    getCurrentRecording(String captureAgentId)
     
    org.opencastproject.metadata.dublincore.DublinCoreCatalog
    getDublinCore(String mediaPackageId)
     
    int
    getEventCount()
     
    Map<String,org.opencastproject.scheduler.api.Recording>
    getKnownRecordings()
     
    org.opencastproject.mediapackage.MediaPackage
    getMediaPackage(String mediaPackageId)
     
    org.opencastproject.scheduler.api.Recording
    getRecordingState(String id)
     
    String
    getScheduleLastModified(String captureAgentId)
     
    org.opencastproject.security.api.SecurityService
    getSecurityService()
     
    org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.Service
    getService()
     
    org.opencastproject.scheduler.api.TechnicalMetadata
    getTechnicalMetadata(String mediaPackageId)
     
    com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage>
    getUpcomingRecording(String captureAgentId)
     
    Map<String,String>
    getWorkflowConfig(String mediaPackageId)
     
    void
    removeCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)
    OSGi callback to remove EventCatalogUIAdapter instance.
    void
    removeEvent(String mediaPackageId)
     
    void
    removeRecording(String id)
     
    void
    removeScheduledRecordingsBeforeBuffer(long buffer)
     
    void
    removeSchedulerUpdateHandler(org.opencastproject.message.broker.api.update.SchedulerUpdateHandler handler)
     
    void
    repopulate(org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.DataType type)
     
    List<org.opencastproject.mediapackage.MediaPackage>
    search(com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<Date> startsFrom, com.entwinemedia.fn.data.Opt<Date> startsTo, com.entwinemedia.fn.data.Opt<Date> endFrom, com.entwinemedia.fn.data.Opt<Date> endTo)
     
    void
    setAssetManager(org.opencastproject.assetmanager.api.AssetManager assetManager)
    OSGi callback to set the asset manager.
    void
    setAuthorizationService(org.opencastproject.security.api.AuthorizationService authorizationService)
    OSGi callback to set the authorization service.
    void
    setIndex(org.opencastproject.elasticsearch.index.ElasticsearchIndex index)
    OSgi callback to set the Elasticsearch index.
    void
    setOrgDirectoryService(org.opencastproject.security.api.OrganizationDirectoryService orgDirectoryService)
    OSGi callback to set the organization directory service.
    void
    setPersistence(SchedulerServiceDatabase persistence)
    OSGi callback to set Persistence Service.
    void
    setSecurityService(org.opencastproject.security.api.SecurityService securityService)
    OSGi callback to set security service.
    void
    setSeriesService(org.opencastproject.series.api.SeriesService seriesService)
    OSGi callback for setting Series Service.
    void
    setWorkspace(org.opencastproject.workspace.api.Workspace workspace)
    OSGi callback to set the workspace.
    void
    updated(Dictionary<String,?> properties)
     
    void
    updateEvent(String mpId, com.entwinemedia.fn.data.Opt<Date> startDateTime, com.entwinemedia.fn.data.Opt<Date> endDateTime, com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<Set<String>> userIds, com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage> mediaPackage, com.entwinemedia.fn.data.Opt<Map<String,String>> wfProperties, com.entwinemedia.fn.data.Opt<Map<String,String>> caMetadata)
     
    void
    updateEvent(String mpId, com.entwinemedia.fn.data.Opt<Date> startDateTime, com.entwinemedia.fn.data.Opt<Date> endDateTime, com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<Set<String>> userIds, com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage> mediaPackage, com.entwinemedia.fn.data.Opt<Map<String,String>> wfProperties, com.entwinemedia.fn.data.Opt<Map<String,String>> caMetadata, boolean allowConflict)
     
    boolean
    updateRecordingState(String id, String state)
     

    Methods inherited from class org.opencastproject.elasticsearch.index.rebuild.AbstractIndexProducer

    logIndexRebuildBegin, logIndexRebuildBegin, logIndexRebuildError, logIndexRebuildError, logIndexRebuildError, logIndexRebuildProgress, logIndexRebuildProgress, logIndexRebuildProgress, logIndexRebuildProgress, logSkippingElement, logSkippingElement

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.opencastproject.elasticsearch.index.rebuild.IndexProducer

    dataTypeSupported, getSupportedDataTypes

  • Field Details

    • lastModifiedCache

      protected com.google.common.cache.Cache<String,String> lastModifiedCache
      The last modified cache

  • Constructor Details

    • SchedulerServiceImpl

      public SchedulerServiceImpl()

  • Method Details

    • addSchedulerUpdateHandler

      public void addSchedulerUpdateHandler(org.opencastproject.message.broker.api.update.SchedulerUpdateHandler handler)
      OSGi callback to add an update handler.
      Parameters:
      handler -

    • removeSchedulerUpdateHandler

      public void removeSchedulerUpdateHandler(org.opencastproject.message.broker.api.update.SchedulerUpdateHandler handler)

    • setPersistence

      public void setPersistence(SchedulerServiceDatabase persistence)
      OSGi callback to set Persistence Service.
      Parameters:
      persistence -

    • setSeriesService

      public void setSeriesService(org.opencastproject.series.api.SeriesService seriesService)
      OSGi callback for setting Series Service.
      Parameters:
      seriesService -

    • setSecurityService

      public void setSecurityService(org.opencastproject.security.api.SecurityService securityService)
      OSGi callback to set security service.
      Parameters:
      securityService -

    • setAssetManager

      public void setAssetManager(org.opencastproject.assetmanager.api.AssetManager assetManager)
      OSGi callback to set the asset manager.
      Parameters:
      assetManager -

    • setWorkspace

      public void setWorkspace(org.opencastproject.workspace.api.Workspace workspace)
      OSGi callback to set the workspace.
      Parameters:
      workspace -

    • setAuthorizationService

      public void setAuthorizationService(org.opencastproject.security.api.AuthorizationService authorizationService)
      OSGi callback to set the authorization service.
      Parameters:
      authorizationService -

    • setOrgDirectoryService

      public void setOrgDirectoryService(org.opencastproject.security.api.OrganizationDirectoryService orgDirectoryService)
      OSGi callback to set the organization directory service.
      Parameters:
      orgDirectoryService -

    • setIndex

      public void setIndex(org.opencastproject.elasticsearch.index.ElasticsearchIndex index)
      OSgi callback to set the Elasticsearch index.
      Parameters:
      index - the Elasticsearch index.

    • addCatalogUIAdapter

      public void addCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)
      OSGi callback to add EventCatalogUIAdapter instance.

    • removeCatalogUIAdapter

      public void removeCatalogUIAdapter(org.opencastproject.metadata.dublincore.EventCatalogUIAdapter catalogUIAdapter)
      OSGi callback to remove EventCatalogUIAdapter instance.

    • activate

      public void activate(org.osgi.service.component.ComponentContext cc) throws Exception
      Activates Scheduler Service.
      Parameters:
      cc - ComponentContext
      Throws:
      Exception

    • updated

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

    • addEvent

      public void addEvent(Date startDateTime, Date endDateTime, String captureAgentId, Set<String> userIds, org.opencastproject.mediapackage.MediaPackage mediaPackage, Map<String,String> wfProperties, Map<String,String> caMetadata, com.entwinemedia.fn.data.Opt<String> schedulingSource) throws org.opencastproject.security.api.UnauthorizedException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      addEvent in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.security.api.UnauthorizedException
      org.opencastproject.scheduler.api.SchedulerException

    • addMultipleEvents

      public Map<String,net.fortuna.ical4j.model.Period> addMultipleEvents(net.fortuna.ical4j.model.property.RRule rRule, Date start, Date end, Long duration, TimeZone tz, String captureAgentId, Set<String> userIds, org.opencastproject.mediapackage.MediaPackage templateMp, Map<String,String> wfProperties, Map<String,String> caMetadata, com.entwinemedia.fn.data.Opt<String> schedulingSource) throws org.opencastproject.security.api.UnauthorizedException, org.opencastproject.scheduler.api.SchedulerConflictException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      addMultipleEvents in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.security.api.UnauthorizedException
      org.opencastproject.scheduler.api.SchedulerConflictException
      org.opencastproject.scheduler.api.SchedulerException

    • updateEvent

      public void updateEvent(String mpId, com.entwinemedia.fn.data.Opt<Date> startDateTime, com.entwinemedia.fn.data.Opt<Date> endDateTime, com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<Set<String>> userIds, com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage> mediaPackage, com.entwinemedia.fn.data.Opt<Map<String,String>> wfProperties, com.entwinemedia.fn.data.Opt<Map<String,String>> caMetadata) throws org.opencastproject.util.NotFoundException, org.opencastproject.security.api.UnauthorizedException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      updateEvent in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.security.api.UnauthorizedException
      org.opencastproject.scheduler.api.SchedulerException

    • updateEvent

      public void updateEvent(String mpId, com.entwinemedia.fn.data.Opt<Date> startDateTime, com.entwinemedia.fn.data.Opt<Date> endDateTime, com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<Set<String>> userIds, com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage> mediaPackage, com.entwinemedia.fn.data.Opt<Map<String,String>> wfProperties, com.entwinemedia.fn.data.Opt<Map<String,String>> caMetadata, boolean allowConflict) throws org.opencastproject.util.NotFoundException, org.opencastproject.security.api.UnauthorizedException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      updateEvent in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.security.api.UnauthorizedException
      org.opencastproject.scheduler.api.SchedulerException

    • removeEvent

      public void removeEvent(String mediaPackageId) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      removeEvent in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • getMediaPackage

      public org.opencastproject.mediapackage.MediaPackage getMediaPackage(String mediaPackageId) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getMediaPackage in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • getDublinCore

      public org.opencastproject.metadata.dublincore.DublinCoreCatalog getDublinCore(String mediaPackageId) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getDublinCore in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • getTechnicalMetadata

      public org.opencastproject.scheduler.api.TechnicalMetadata getTechnicalMetadata(String mediaPackageId) throws org.opencastproject.util.NotFoundException, org.opencastproject.security.api.UnauthorizedException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getTechnicalMetadata in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.security.api.UnauthorizedException
      org.opencastproject.scheduler.api.SchedulerException

    • getWorkflowConfig

      public Map<String,String> getWorkflowConfig(String mediaPackageId) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getWorkflowConfig in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • getCaptureAgentConfiguration

      public Map<String,String> getCaptureAgentConfiguration(String mediaPackageId) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getCaptureAgentConfiguration in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • getEventCount

      public int getEventCount() throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getEventCount in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • search

      public List<org.opencastproject.mediapackage.MediaPackage> search(com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<Date> startsFrom, com.entwinemedia.fn.data.Opt<Date> startsTo, com.entwinemedia.fn.data.Opt<Date> endFrom, com.entwinemedia.fn.data.Opt<Date> endTo) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      search in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • getCurrentRecording

      public com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage> getCurrentRecording(String captureAgentId) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getCurrentRecording in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • getUpcomingRecording

      public com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage> getUpcomingRecording(String captureAgentId) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getUpcomingRecording in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • findConflictingEvents

      public List<org.opencastproject.mediapackage.MediaPackage> findConflictingEvents(String captureDeviceID, Date startDate, Date endDate) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      findConflictingEvents in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • findConflictingEvents

      public List<org.opencastproject.mediapackage.MediaPackage> findConflictingEvents(String captureAgentId, net.fortuna.ical4j.model.property.RRule rrule, Date start, Date end, long duration, TimeZone tz) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      findConflictingEvents in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • getCalendar

      public String getCalendar(com.entwinemedia.fn.data.Opt<String> captureAgentId, com.entwinemedia.fn.data.Opt<String> seriesId, com.entwinemedia.fn.data.Opt<Date> cutoff) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getCalendar in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • getScheduleLastModified

      public String getScheduleLastModified(String captureAgentId) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getScheduleLastModified in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • removeScheduledRecordingsBeforeBuffer

      public void removeScheduledRecordingsBeforeBuffer(long buffer) throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      removeScheduledRecordingsBeforeBuffer in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • updateRecordingState

      public boolean updateRecordingState(String id, String state) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      updateRecordingState in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • getRecordingState

      public org.opencastproject.scheduler.api.Recording getRecordingState(String id) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getRecordingState in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • removeRecording

      public void removeRecording(String id) throws org.opencastproject.util.NotFoundException, org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      removeRecording in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.util.NotFoundException
      org.opencastproject.scheduler.api.SchedulerException

    • getKnownRecordings

      public Map<String,org.opencastproject.scheduler.api.Recording> getKnownRecordings() throws org.opencastproject.scheduler.api.SchedulerException
      Specified by:
      getKnownRecordings in interface org.opencastproject.scheduler.api.SchedulerService
      Throws:
      org.opencastproject.scheduler.api.SchedulerException

    • repopulate

      public void repopulate(org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.DataType type) throws org.opencastproject.elasticsearch.index.rebuild.IndexRebuildException
      Specified by:
      repopulate in interface org.opencastproject.elasticsearch.index.rebuild.IndexProducer
      Throws:
      org.opencastproject.elasticsearch.index.rebuild.IndexRebuildException

    • getService

      public org.opencastproject.elasticsearch.index.rebuild.IndexRebuildService.Service getService()
      Specified by:
      getService in interface org.opencastproject.elasticsearch.index.rebuild.IndexProducer

    • getSecurityService

      public org.opencastproject.security.api.SecurityService getSecurityService()