org.duracloud.s3task.streaming

Class AddStreamingItemTaskRunner

java.lang.Object

org.duracloud.s3task.streaming.BaseStreamingTaskRunner

org.duracloud.s3task.streaming.AddStreamingItemTaskRunner

All Implemented Interfaces:

TaskRunner

public class AddStreamingItemTaskRunner
extends BaseStreamingTaskRunner

The purpose of this task is to add an additional item to a pre-existing streaming distribution.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AddStreamingItemTaskRunner.TaskParams

Field Summary

Fields inherited from class org.duracloud.s3task.streaming.BaseStreamingTaskRunner

cfService, maxRetries, s3Client, s3Provider

Constructor Summary

Constructors

Constructor and Description
AddStreamingItemTaskRunner(S3StorageProvider s3Provider, com.amazonaws.services.s3.AmazonS3Client s3Client, org.jets3t.service.CloudFrontService cfService)

Method Summary

Methods

Modifier and Type	Method and Description
String	getName()
protected AddStreamingItemTaskRunner.TaskParams	parseTaskParams(String taskParameters)
String	performTask(String taskParameters)

Methods inherited from class org.duracloud.s3task.streaming.BaseStreamingTaskRunner

getAllExistingDistributions, getDistributionOriginAccessId, getExistingDistribution, getSpaceContents, getSpaceId, setACL, wait

Methods inherited from class java.lang.Object

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

Constructor Detail

AddStreamingItemTaskRunner

public AddStreamingItemTaskRunner(S3StorageProvider s3Provider,
                          com.amazonaws.services.s3.AmazonS3Client s3Client,
                          org.jets3t.service.CloudFrontService cfService)

Method Detail

getName

public String getName()

Specified by:

getName in interface TaskRunner

Specified by:

getName in class BaseStreamingTaskRunner

parseTaskParams

protected AddStreamingItemTaskRunner.TaskParams parseTaskParams(String taskParameters)

performTask

public String performTask(String taskParameters)

Specified by:

performTask in interface TaskRunner

Specified by:

performTask in class BaseStreamingTaskRunner