Added an option to download output asset files

Author: Yoichi Kawasaki

src/main/java/azuremediaprocessor/Client.java

@@ -117,7 +117,16 @@ public void PrintMediaProcessorsList()
     public void RunMediaProcessingJob( String mediaProcessorName,
                                         String assetName,
                                         String taskParamFile,
-                                        String outputDir ) 
+                                        String outputDir )
+                                            throws InterruptedException, ServiceException {
+        this.RunMediaProcessingJob(mediaProcessorName, assetName, taskParamFile, outputDir, true);
+    } 
+
+    public void RunMediaProcessingJob( String mediaProcessorName,
+                                        String assetName,
+                                        String taskParamFile,
+                                        String outputDir,
+                                        Boolean downloadFiles ) 
                                             throws InterruptedException, ServiceException {
         // Use latest media processor
         ListResult<MediaProcessorInfo> mpis
@@ -141,7 +150,9 @@ public void RunMediaProcessingJob( String mediaProcessorName,
                                     this.service,
                                     assetName,
                                     taskParamFile,
-                                    outputDir);
+                                    outputDir,
+                                    downloadFiles);
+
         procRunner.addObserver(listener);
 
         Thread procThread = new Thread(procRunner);

src/main/java/azuremediaprocessor/MediaProcessRunner.java

@@ -37,6 +37,7 @@ public class MediaProcessRunner extends Subject implements Runnable {
     private String assetName;
     private String taskParamFile;
     private String outputDir;
+    private Boolean downloadFiles;
     private AssetInfo mediaAsset;
     private MediaContract service;
 
@@ -50,27 +51,31 @@ public MediaProcessRunner(
             MediaContract service,
             String assetName,
             String taskParamFile,
-            String outputDir) {
+            String outputDir,
+            Boolean downloadFiles) {
         this.state = new State();
         this.state.setValue("Initiating");
         this.service = service;
         this.assetName = assetName;
         this.taskParamFile = taskParamFile;
         this.outputDir = outputDir;
+        this.downloadFiles = downloadFiles;
     }
 
     public MediaProcessRunner( 
             MediaContract service,
             String assetName,
             String taskParamFile,
             String outputDir,
+            Boolean downloadFiles,
             String state,
             int progress) {
         this.state = new State();
         this.service = service;
         this.assetName = assetName;
         this.taskParamFile = taskParamFile;
         this.outputDir = outputDir;
+        this.downloadFiles = downloadFiles;
         this.state.setValue(state);
         this.state.setProgress(progress);
     }
@@ -115,7 +120,10 @@ public void run() {
             }
             checkJobStatus(jobId);
 
-            downloadProcessedAssetFilesFromJob(jobInfo);
+            // Download output asset files only if opted
+            if (downloadFiles) {
+                downloadProcessedAssetFilesFromJob(jobInfo);
+            }
         } catch (Exception e) {
              System.err.println("Exception occured while running media processing job: "
                                         + e.getMessage());