Package org.opencastproject.distribution.aws.s3.remote

Class AwsS3DistributionServiceRemoteImpl

java.lang.Object

org.opencastproject.serviceregistry.api.RemoteBase

org.opencastproject.distribution.aws.s3.remote.AwsS3DistributionServiceRemoteImpl

All Implemented Interfaces:

DistributionService, DownloadDistributionService, AwsS3DistributionService

public class AwsS3DistributionServiceRemoteImpl
extends RemoteBase
implements AwsS3DistributionService, DownloadDistributionService

This is a copy of DownloadDistributionServiceRemoteImpl.

Author:

rsantos

Nested Class Summary

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

RemoteBase.HttpClientClosingInputStream

Field Summary

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
AwsS3DistributionServiceRemoteImpl()

Method Summary

Modifier and Type	Method	Description
protected void	activate(org.osgi.service.component.ComponentContext cc)	activates the component
Job	distribute(String channelId, MediaPackage mediaPackage, String elementId)	Distribute a media package element.
Job	distribute(String channelId, MediaPackage mediaPackage, String elementId, boolean checkAvailability)
Job	distribute(String channelId, MediaPackage mediaPackage, Set<String> elementIds, boolean checkAvailability)
Job	distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds, boolean checkAvailability, boolean preserveReference)
List<MediaPackageElement>	distributeSync(String channelId, MediaPackage mediaPackage, String elementId)	Distributes a media package element synchronously, bypassing the Opencast job system.
List<MediaPackageElement>	distributeSync(String channelId, MediaPackage mediapackage, Set<String> elementIds, boolean checkAvailability)	Distributes the given elements synchronously.
String	getDistributionType()	Returns the distribution type for this service.
Job	retract(String channelId, MediaPackage mediaPackage, String elementId)	Retract a media package element from the distribution channel.
Job	retract(String channelId, MediaPackage mediaPackage, Set<String> elementIds)
List<MediaPackageElement>	retractSync(String channelId, MediaPackage mediaPackage, String elementId)	Retract a media package element from the distribution channel synchronously, bypassing the Opencast job system.
List<MediaPackageElement>	retractSync(String channelId, MediaPackage mediaPackage, Set<String> elementIds)	Retracts the given elements synchronously.
void	setRemoteServiceManager(ServiceRegistry serviceRegistry)	Sets the remote service manager.
void	setTrustedHttpClient(TrustedHttpClient trustedHttpClient)	Sets the trusted http client

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

AwsS3DistributionServiceRemoteImpl

public AwsS3DistributionServiceRemoteImpl()

Method Details

activate

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

activates the component

getDistributionType

public String getDistributionType()

Description copied from interface: DistributionService

Returns the distribution type for this service. This type should be unique within an Opencast instance, and is used to select where file distribution happens.

Specified by:

getDistributionType in interface DistributionService

Returns:

The distribution type. A string like "download", or "streaming"

distribute

public Job distribute(String channelId,
 MediaPackage mediaPackage,
 String elementId)
               throws DistributionException

Description copied from interface: DistributionService

Distribute a media package element.

Specified by:

distribute in interface DistributionService

Parameters:

mediaPackage - the media package

elementId - the element in the media package to distribute

Returns:

The job

Throws:

DistributionException - if there was a problem distributing the media

distribute

public Job distribute(String channelId,
 MediaPackage mediaPackage,
 String elementId,
 boolean checkAvailability)
               throws DistributionException

Specified by:

distribute in interface DownloadDistributionService

Throws:

DistributionException

distribute

public Job distribute(String channelId,
 MediaPackage mediaPackage,
 Set<String> elementIds,
 boolean checkAvailability)
               throws DistributionException

Specified by:

distribute in interface DownloadDistributionService

Throws:

DistributionException

retract

public Job retract(String channelId,
 MediaPackage mediaPackage,
 String elementId)
            throws DistributionException

Description copied from interface: DistributionService

Retract a media package element from the distribution channel.

Specified by:

retract in interface DistributionService

Parameters:

mediaPackage - the media package

elementId - the media package element to retract

Throws:

DistributionException - if there was a problem retracting the mediapackage

retract

public Job retract(String channelId,
 MediaPackage mediaPackage,
 Set<String> elementIds)
            throws DistributionException

Specified by:

retract in interface DownloadDistributionService

Throws:

DistributionException

distributeSync

public List<MediaPackageElement> distributeSync(String channelId,
 MediaPackage mediaPackage,
 String elementId)
                                         throws DistributionException

Description copied from interface: DistributionService

Distributes a media package element synchronously, bypassing the Opencast job system.

Specified by:

distributeSync in interface DistributionService

Parameters:

mediaPackage - the media package

elementId - the element in the media package to distribute

Returns:

list of distributed media package elements

Throws:

DistributionException - if there was a problem distributing the media

distributeSync

public List<MediaPackageElement> distributeSync(String channelId,
 MediaPackage mediapackage,
 Set<String> elementIds,
 boolean checkAvailability)
                                         throws DistributionException

Description copied from interface: DownloadDistributionService

Distributes the given elements synchronously. This should be used rarely since load balancing will be unavailable. However, since the dispatching logic is bypassed, synchronous execution is much faster. It is useful in interactive scenarios where you synchronously wait for job execution anyway and you don't want to make the user waiting for too long.

Specified by:

distributeSync in interface DownloadDistributionService

Parameters:

channelId - The channel to retract from.

mediapackage - A media package holding the elements to retract.

elementIds - The IDs of the elements to retract.

checkAvailability - Whether to check if the distributed elements are available through their URI.

Returns:

The distributed elements.

Throws:

DistributionException - In case distribution fails.

retractSync

public List<MediaPackageElement> retractSync(String channelId,
 MediaPackage mediaPackage,
 String elementId)
                                      throws DistributionException

Description copied from interface: DistributionService

Retract a media package element from the distribution channel synchronously, bypassing the Opencast job system.

Specified by:

retractSync in interface DistributionService

Parameters:

mediaPackage - the media package

elementId - the media package element to retract

Returns:

list of retracted media package elements

Throws:

DistributionException - if there was a problem retracting the mediapackage

retractSync

public List<MediaPackageElement> retractSync(String channelId,
 MediaPackage mediaPackage,
 Set<String> elementIds)
                                      throws DistributionException

Description copied from interface: DownloadDistributionService

Retracts the given elements synchronously. This should be used rarely since load balancing will be unavailable. However, since the dispatching logic is bypassed, synchronous execution is much faster. It is useful in interactive scenarios where you synchronously wait for job execution anyway and you don't want to make the user waiting for too long.

Specified by:

retractSync in interface DownloadDistributionService

Parameters:

channelId - The channel to retract from.

mediaPackage - A media package holding the elements to retract.

elementIds - The IDs of the elements to retract.

Returns:

The retracted elements.

Throws:

DistributionException - In case retraction fails.

distribute

public Job distribute(String pubChannelId,
 MediaPackage mediaPackage,
 Set<String> downloadIds,
 boolean checkAvailability,
 boolean preserveReference)
               throws DistributionException,
MediaPackageException

Specified by:

distribute in interface DownloadDistributionService

Throws:

DistributionException

MediaPackageException

setTrustedHttpClient

public void setTrustedHttpClient(TrustedHttpClient trustedHttpClient)

Description copied from class: RemoteBase

Sets the trusted http client

Overrides:

setTrustedHttpClient in class RemoteBase

Parameters:

trustedHttpClient -

setRemoteServiceManager

public void setRemoteServiceManager(ServiceRegistry serviceRegistry)

Description copied from class: RemoteBase

Sets the remote service manager.

Overrides:

setRemoteServiceManager in class RemoteBase

Parameters:

serviceRegistry -