@Test public void testDistributeMultipleJob() throws Exception { Set<String> mpeIds = new LinkedHashSet<String>(); mpeIds.add("presenter-delivery"); boolean checkAvailability = false; List<String> args = new LinkedList<String>(); args.add("channelId"); args.add(MediaPackageParser.getAsXml(mp)); args.add(gson.toJson(mpeIds)); args.add(Boolean.toString(checkAvailability)); EasyMock.expect( serviceRegistry.createJob( AwsS3DistributionServiceImpl.JOB_TYPE, AwsS3DistributionServiceImpl.Operation.Distribute.toString(), args, AwsS3DistributionServiceImpl.DEFAULT_DISTRIBUTE_JOB_LOAD )).andReturn(null).once(); EasyMock.replay(serviceRegistry); service.distribute("channelId", mp, mpeIds, checkAvailability); EasyMock.verify(serviceRegistry); }
@Override public Job distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds, boolean checkAvailability, boolean preserveReference) throws DistributionException, MediaPackageException { throw new UnsupportedOperationException("Not supported yet."); }
AwsS3DistributionServiceImpl extends AbstractDistributionService implements AwsS3DistributionService, DistributionService { @Override public Job distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds, boolean checkAvailability, boolean preserveReference) throws DistributionException, MediaPackageException { throw new UnsupportedOperationException("Not supported yet."); } }
AwsS3DistributionServiceImpl extends AbstractDistributionService implements AwsS3DistributionService, DistributionService { @Override public Job distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds, boolean checkAvailability, boolean preserveReference) throws DistributionException, MediaPackageException { throw new UnsupportedOperationException("Not supported yet."); } AwsS3DistributionServiceImpl(); }
AwsS3DistributionServiceImpl extends AbstractDistributionService implements AwsS3DistributionService, DistributionService { @Override public Job distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds, boolean checkAvailability, boolean preserveReference) throws DistributionException, MediaPackageException { throw new UnsupportedOperationException("Not supported yet."); } AwsS3DistributionServiceImpl(); @Override void activate(ComponentContext cc); @Override String getDistributionType(); void deactivate(); @Override Job distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds,
    boolean checkAvailability, boolean preserveReference); @Override Job distribute(String channelId, MediaPackage mediaPackage, Set<String> elementIds, boolean checkAvailability); @Override Job distribute(String channelId, MediaPackage mediapackage, String elementId); @Override Job distribute(String channelId, MediaPackage mediaPackage, String elementId, boolean checkAvailability); MediaPackageElement[] distributeElements(String channelId, MediaPackage mediapackage, Set<String> elementIds,
          boolean checkAvailability); MediaPackageElement distributeElement(String channelId, final MediaPackage mediaPackage,
          MediaPackageElement element, boolean checkAvailability); @Override Job retract(String channelId, MediaPackage mediapackage, String elementId); @Override Job retract(String channelId, MediaPackage mediapackage, Set<String> elementIds); @Override List<MediaPackageElement> distributeSync(String channelId, MediaPackage mediapackage, Set<String> elementIds,
         boolean checkAvailability); @Override List<MediaPackageElement> retractSync(String channelId, MediaPackage mediaPackage, Set<String> elementIds); @Override Job restore(String channelId, MediaPackage mediaPackage, String elementId); @Override Job restore(String channelId, MediaPackage mediaPackage, String elementId, String fileName); }
AwsS3DistributionServiceImpl extends AbstractDistributionService implements AwsS3DistributionService, DistributionService { @Override public Job distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds, boolean checkAvailability, boolean preserveReference) throws DistributionException, MediaPackageException { throw new UnsupportedOperationException("Not supported yet."); } AwsS3DistributionServiceImpl(); @Override void activate(ComponentContext cc); @Override String getDistributionType(); void deactivate(); @Override Job distribute(String pubChannelId, MediaPackage mediaPackage, Set<String> downloadIds,
    boolean checkAvailability, boolean preserveReference); @Override Job distribute(String channelId, MediaPackage mediaPackage, Set<String> elementIds, boolean checkAvailability); @Override Job distribute(String channelId, MediaPackage mediapackage, String elementId); @Override Job distribute(String channelId, MediaPackage mediaPackage, String elementId, boolean checkAvailability); MediaPackageElement[] distributeElements(String channelId, MediaPackage mediapackage, Set<String> elementIds,
          boolean checkAvailability); MediaPackageElement distributeElement(String channelId, final MediaPackage mediaPackage,
          MediaPackageElement element, boolean checkAvailability); @Override Job retract(String channelId, MediaPackage mediapackage, String elementId); @Override Job retract(String channelId, MediaPackage mediapackage, Set<String> elementIds); @Override List<MediaPackageElement> distributeSync(String channelId, MediaPackage mediapackage, Set<String> elementIds,
         boolean checkAvailability); @Override List<MediaPackageElement> retractSync(String channelId, MediaPackage mediaPackage, Set<String> elementIds); @Override Job restore(String channelId, MediaPackage mediaPackage, String elementId); @Override Job restore(String channelId, MediaPackage mediaPackage, String elementId, String fileName); static final String JOB_TYPE; static final String AWS_S3_DISTRIBUTION_ENABLE; static final String AWS_S3_DISTRIBUTION_BASE_CONFIG; static final String AWS_S3_ACCESS_KEY_ID_CONFIG; static final String AWS_S3_SECRET_ACCESS_KEY_CONFIG; static final String AWS_S3_REGION_CONFIG; static final String AWS_S3_BUCKET_CONFIG; static final String AWS_S3_ENDPOINT_CONFIG; static final String AWS_S3_PATH_STYLE_CONFIG; static final String OPENCAST_DOWNLOAD_URL; static final String OPENCAST_STORAGE_DIR; static final String DEFAULT_TEMP_DIR; static final float DEFAULT_DISTRIBUTE_JOB_LOAD; static final float DEFAULT_RETRACT_JOB_LOAD; static final float DEFAULT_RESTORE_JOB_LOAD; static final String DISTRIBUTE_JOB_LOAD_KEY; static final String RETRACT_JOB_LOAD_KEY; static final String RESTORE_JOB_LOAD_KEY; }