EnableStreamingTaskRunner extends BaseStreamingTaskRunner { public String getName() { return TASK_NAME; } EnableStreamingTaskRunner(StorageProvider s3Provider,
                                     S3StorageProvider unwrappedS3Provider,
                                     AmazonS3 s3Client,
                                     AmazonCloudFrontClient cfClient,
                                     String cfAccountId); String getName(); String performTask(String taskParameters);  }
@Test public void testGetName() throws Exception { EnableStreamingTaskRunner runner = createRunner(createMockStorageProvider(), createMockUnwrappedS3StorageProvider(), createMockS3ClientV1(), createMockCFClientV1(), cfAccountId); String name = runner.getName(); assertEquals("enable-streaming", name); }