Package org.opencastproject.scheduler.remote

Class SchedulerServiceRemoteImpl

java.lang.Object

org.opencastproject.serviceregistry.api.RemoteBase

org.opencastproject.scheduler.remote.SchedulerServiceRemoteImpl

All Implemented Interfaces:

org.opencastproject.scheduler.api.SchedulerService

public class SchedulerServiceRemoteImpl
extends org.opencastproject.serviceregistry.api.RemoteBase
implements org.opencastproject.scheduler.api.SchedulerService

A proxy to a remote series service.

Nested Class Summary

Nested classes/interfaces inherited from class org.opencastproject.serviceregistry.api.RemoteBase

org.opencastproject.serviceregistry.api.RemoteBase.HttpClientClosingInputStream

Field Summary

Fields inherited from class org.opencastproject.serviceregistry.api.RemoteBase

client, elementsFromHttpResponse, remoteServiceManager, serviceType

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

JOB_TYPE, WORKFLOW_CONFIG_PREFIX

Constructor Summary

Constructors

Constructor	Description
SchedulerServiceRemoteImpl()

Method Summary

Modifier and Type	Method	Description
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)
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 startDate, Date endDate, long duration, TimeZone timezone)
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 eventId)
com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage>	getCurrentRecording(String captureAgentId)
org.opencastproject.metadata.dublincore.DublinCoreCatalog	getDublinCore(String eventId)
int	getEventCount()
Map<String,org.opencastproject.scheduler.api.Recording>	getKnownRecordings()
org.opencastproject.mediapackage.MediaPackage	getMediaPackage(String eventId)
org.opencastproject.scheduler.api.Recording	getRecordingState(String id)
String	getScheduleLastModified(String agentId)
org.opencastproject.scheduler.api.TechnicalMetadata	getTechnicalMetadata(String eventId)
com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage>	getUpcomingRecording(String captureAgentId)
Map<String,String>	getWorkflowConfig(String eventId)
void	removeEvent(String eventId)
void	removeRecording(String eventId)
void	removeScheduledRecordingsBeforeBuffer(long buffer)
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	setRemoteServiceManager(org.opencastproject.serviceregistry.api.ServiceRegistry serviceRegistry)
void	setTrustedHttpClient(org.opencastproject.security.api.TrustedHttpClient trustedHttpClient)
void	updateEvent(String eventId, 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 eventId, 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 mediapackageId, String state)

Methods inherited from class org.opencastproject.serviceregistry.api.RemoteBase

closeConnection, getResponse, getResponse, runRequest

Methods inherited from class java.lang.Object

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

Constructor Details

SchedulerServiceRemoteImpl

public SchedulerServiceRemoteImpl()

Method Details

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.SchedulerConflictException,
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.SchedulerConflictException

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 eventId,
 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.SchedulerConflictException,
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.SchedulerConflictException

org.opencastproject.scheduler.api.SchedulerException

updateEvent

public void updateEvent(String eventId,
 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.SchedulerConflictException,
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.SchedulerConflictException

org.opencastproject.scheduler.api.SchedulerException

removeEvent

public void removeEvent(String eventId)
                 throws org.opencastproject.util.NotFoundException,
org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

removeEvent in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.util.NotFoundException

org.opencastproject.security.api.UnauthorizedException

org.opencastproject.scheduler.api.SchedulerException

getMediaPackage

public org.opencastproject.mediapackage.MediaPackage getMediaPackage(String eventId)
                                                              throws org.opencastproject.util.NotFoundException,
org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

getMediaPackage in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.util.NotFoundException

org.opencastproject.security.api.UnauthorizedException

org.opencastproject.scheduler.api.SchedulerException

getDublinCore

public org.opencastproject.metadata.dublincore.DublinCoreCatalog getDublinCore(String eventId)
                                                                        throws org.opencastproject.util.NotFoundException,
org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

getDublinCore in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.util.NotFoundException

org.opencastproject.security.api.UnauthorizedException

org.opencastproject.scheduler.api.SchedulerException

getTechnicalMetadata

public org.opencastproject.scheduler.api.TechnicalMetadata getTechnicalMetadata(String eventId)
                                                                         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 eventId)
                                     throws org.opencastproject.util.NotFoundException,
org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

getWorkflowConfig in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.util.NotFoundException

org.opencastproject.security.api.UnauthorizedException

org.opencastproject.scheduler.api.SchedulerException

getCaptureAgentConfiguration

public Map<String,String> getCaptureAgentConfiguration(String eventId)
                                                throws org.opencastproject.util.NotFoundException,
org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

getCaptureAgentConfiguration in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.util.NotFoundException

org.opencastproject.security.api.UnauthorizedException

org.opencastproject.scheduler.api.SchedulerException

getEventCount

public int getEventCount()
                  throws org.opencastproject.scheduler.api.SchedulerException,
org.opencastproject.security.api.UnauthorizedException

Specified by:

getEventCount in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.scheduler.api.SchedulerException

org.opencastproject.security.api.UnauthorizedException

getScheduleLastModified

public String getScheduleLastModified(String agentId)
                               throws org.opencastproject.scheduler.api.SchedulerException

Specified by:

getScheduleLastModified 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.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

search in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.security.api.UnauthorizedException

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,
org.opencastproject.security.api.UnauthorizedException

Specified by:

getCurrentRecording in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.scheduler.api.SchedulerException

org.opencastproject.security.api.UnauthorizedException

getUpcomingRecording

public com.entwinemedia.fn.data.Opt<org.opencastproject.mediapackage.MediaPackage> getUpcomingRecording(String captureAgentId)
                                                                                                 throws org.opencastproject.scheduler.api.SchedulerException,
org.opencastproject.security.api.UnauthorizedException

Specified by:

getUpcomingRecording in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.scheduler.api.SchedulerException

org.opencastproject.security.api.UnauthorizedException

findConflictingEvents

public List<org.opencastproject.mediapackage.MediaPackage> findConflictingEvents(String captureDeviceID,
 Date startDate,
 Date endDate)
                                                                          throws org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

findConflictingEvents in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.security.api.UnauthorizedException

org.opencastproject.scheduler.api.SchedulerException

findConflictingEvents

public List<org.opencastproject.mediapackage.MediaPackage> findConflictingEvents(String captureAgentId,
 net.fortuna.ical4j.model.property.RRule rrule,
 Date startDate,
 Date endDate,
 long duration,
 TimeZone timezone)
                                                                          throws org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

findConflictingEvents in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.security.api.UnauthorizedException

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

removeScheduledRecordingsBeforeBuffer

public void removeScheduledRecordingsBeforeBuffer(long buffer)
                                           throws org.opencastproject.security.api.UnauthorizedException,
org.opencastproject.scheduler.api.SchedulerException

Specified by:

removeScheduledRecordingsBeforeBuffer in interface org.opencastproject.scheduler.api.SchedulerService

Throws:

org.opencastproject.security.api.UnauthorizedException

org.opencastproject.scheduler.api.SchedulerException

updateRecordingState

public boolean updateRecordingState(String mediapackageId,
 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 eventId)
                     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

setTrustedHttpClient

public void setTrustedHttpClient(org.opencastproject.security.api.TrustedHttpClient trustedHttpClient)

Overrides:

setTrustedHttpClient in class org.opencastproject.serviceregistry.api.RemoteBase

setRemoteServiceManager

public void setRemoteServiceManager(org.opencastproject.serviceregistry.api.ServiceRegistry serviceRegistry)

Overrides:

setRemoteServiceManager in class org.opencastproject.serviceregistry.api.RemoteBase