Package org.opencastproject.distribution.streaming.remote

Class StreamingDistributionServiceRemoteImpl

java.lang.Object
org.opencastproject.serviceregistry.api.RemoteBase
org.opencastproject.distribution.streaming.remote.StreamingDistributionServiceRemoteImpl
All Implemented Interfaces:
org.opencastproject.distribution.api.DistributionService, org.opencastproject.distribution.api.StreamingDistributionService
public class StreamingDistributionServiceRemoteImpl extends org.opencastproject.serviceregistry.api.RemoteBase implements org.opencastproject.distribution.api.StreamingDistributionService
A remote distribution service invoker.

  • Nested Class Summary

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

    org.opencastproject.serviceregistry.api.RemoteBase.HttpClientClosingInputStream

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected String
    distributionChannel
    The distribution channel identifier

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

    client, elementsFromHttpResponse, remoteServiceManager, serviceType

    Fields inherited from interface org.opencastproject.distribution.api.DistributionService

    CONFIG_KEY_STORE_TYPE, JOB_TYPE_PREFIX

  • Constructor Summary

    Constructors
    Constructor
    Description
    StreamingDistributionServiceRemoteImpl()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    activate(org.osgi.service.component.ComponentContext cc)
    activates the component
    org.opencastproject.job.api.Job
    distribute(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId)
     
    org.opencastproject.job.api.Job
    distribute(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, Set<String> elementIds)
     
    List<org.opencastproject.mediapackage.MediaPackageElement>
    distributeSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId)
     
    List<org.opencastproject.mediapackage.MediaPackageElement>
    distributeSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediapackage, Set<String> elementIds)
     
    String
    getDistributionType()
     
    boolean
    publishToStreaming()
     
    org.opencastproject.job.api.Job
    retract(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId)
     
    org.opencastproject.job.api.Job
    retract(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, Set<String> elementIds)
     
    List<org.opencastproject.mediapackage.MediaPackageElement>
    retractSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId)
     
    List<org.opencastproject.mediapackage.MediaPackageElement>
    retractSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, Set<String> elementIds)
     
    void
    setRemoteServiceManager(org.opencastproject.serviceregistry.api.ServiceRegistry serviceRegistry)
     
    void
    setTrustedHttpClient(org.opencastproject.security.api.TrustedHttpClient trustedHttpClient)
     

    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

  • Field Details

    • distributionChannel

      protected String distributionChannel
      The distribution channel identifier

  • Constructor Details

    • StreamingDistributionServiceRemoteImpl

      public StreamingDistributionServiceRemoteImpl()

  • Method Details

    • activate

      protected void activate(org.osgi.service.component.ComponentContext cc)
      activates the component

    • getDistributionType

      public String getDistributionType()
      Specified by:
      getDistributionType in interface org.opencastproject.distribution.api.DistributionService

    • distribute

      public org.opencastproject.job.api.Job distribute(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId) throws org.opencastproject.distribution.api.DistributionException, org.opencastproject.mediapackage.MediaPackageException
      Specified by:
      distribute in interface org.opencastproject.distribution.api.DistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException
      org.opencastproject.mediapackage.MediaPackageException

    • publishToStreaming

      public boolean publishToStreaming()
      Specified by:
      publishToStreaming in interface org.opencastproject.distribution.api.StreamingDistributionService

    • distribute

      public org.opencastproject.job.api.Job distribute(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, Set<String> elementIds) throws org.opencastproject.distribution.api.DistributionException, org.opencastproject.mediapackage.MediaPackageException
      Specified by:
      distribute in interface org.opencastproject.distribution.api.StreamingDistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException
      org.opencastproject.mediapackage.MediaPackageException

    • retract

      public org.opencastproject.job.api.Job retract(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId) throws org.opencastproject.distribution.api.DistributionException
      Specified by:
      retract in interface org.opencastproject.distribution.api.DistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException

    • retract

      public org.opencastproject.job.api.Job retract(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, Set<String> elementIds) throws org.opencastproject.distribution.api.DistributionException
      Specified by:
      retract in interface org.opencastproject.distribution.api.StreamingDistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException

    • distributeSync

      public List<org.opencastproject.mediapackage.MediaPackageElement> distributeSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId) throws org.opencastproject.distribution.api.DistributionException
      Specified by:
      distributeSync in interface org.opencastproject.distribution.api.DistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException

    • distributeSync

      public List<org.opencastproject.mediapackage.MediaPackageElement> distributeSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediapackage, Set<String> elementIds) throws org.opencastproject.distribution.api.DistributionException
      Specified by:
      distributeSync in interface org.opencastproject.distribution.api.StreamingDistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException

    • retractSync

      public List<org.opencastproject.mediapackage.MediaPackageElement> retractSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, String elementId) throws org.opencastproject.distribution.api.DistributionException
      Specified by:
      retractSync in interface org.opencastproject.distribution.api.DistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException

    • retractSync

      public List<org.opencastproject.mediapackage.MediaPackageElement> retractSync(String channelId, org.opencastproject.mediapackage.MediaPackage mediaPackage, Set<String> elementIds) throws org.opencastproject.distribution.api.DistributionException
      Specified by:
      retractSync in interface org.opencastproject.distribution.api.StreamingDistributionService
      Throws:
      org.opencastproject.distribution.api.DistributionException

    • 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