org.duracloud.s3task.streaming
Class BaseStreamingTaskRunner

java.lang.Object
  org.duracloud.s3task.streaming.BaseStreamingTaskRunner

All Implemented Interfaces:

TaskRunner

Direct Known Subclasses:

DeleteStreamingTaskRunner, DisableStreamingTaskRunner, EnableStreamingTaskRunner

public abstract class BaseStreamingTaskRunner
extends java.lang.Object
implements TaskRunner

Field Summary

protected org.jets3t.service.CloudFrontService	cfService
protected S3StorageProvider	s3Provider
protected org.jets3t.service.S3Service	s3Service

Constructor Summary

BaseStreamingTaskRunner()

Method Summary

protected java.util.List<org.jets3t.service.model.cloudfront.StreamingDistribution>	getAllExistingDistributions(java.lang.String bucketName)
protected org.jets3t.service.model.cloudfront.StreamingDistribution	getExistingDistribution(java.lang.String bucketName)
abstract java.lang.String	getName()
protected java.lang.String	getSpaceId(java.lang.String taskParameters)
abstract java.lang.String	performTask(java.lang.String taskParameters)

Methods inherited from class java.lang.Object

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

Field Detail

s3Provider

protected S3StorageProvider s3Provider

s3Service

protected org.jets3t.service.S3Service s3Service

cfService

protected org.jets3t.service.CloudFrontService cfService

Constructor Detail

BaseStreamingTaskRunner

public BaseStreamingTaskRunner()

Method Detail

getName

public abstract java.lang.String getName()

Specified by:

getName in interface TaskRunner

performTask

public abstract java.lang.String performTask(java.lang.String taskParameters)

Specified by:

performTask in interface TaskRunner

getSpaceId

protected java.lang.String getSpaceId(java.lang.String taskParameters)

getExistingDistribution

protected org.jets3t.service.model.cloudfront.StreamingDistribution getExistingDistribution(java.lang.String bucketName)
                                                                                     throws org.jets3t.service.CloudFrontServiceException

Throws:

org.jets3t.service.CloudFrontServiceException

getAllExistingDistributions

protected java.util.List<org.jets3t.service.model.cloudfront.StreamingDistribution> getAllExistingDistributions(java.lang.String bucketName)
                                                                                                         throws org.jets3t.service.CloudFrontServiceException

Throws:

org.jets3t.service.CloudFrontServiceException