org.finra.herd.tools.downloader

Class DownloaderController

java.lang.Object

org.finra.herd.tools.common.databridge.DataBridgeController

org.finra.herd.tools.downloader.DownloaderController

@Component
public class DownloaderController
extends DataBridgeController

Executes the DownloaderApp workflow.

Field Summary

Fields inherited from class org.finra.herd.tools.common.databridge.DataBridgeController

MAX_THREADS, MIN_THREADS, s3Service

Constructor Summary

Constructors

Constructor and Description
DownloaderController()

Method Summary

Modifier and Type	Method and Description
protected DownloaderOutputManifestDto	createDownloaderOutputManifestDto(BusinessObjectData businessObjectData, StorageUnit storageUnit, String s3KeyPrefix) Creates a downloader output manifest instance from the business object data.
void	performDownload(RegServerAccessParamsDto regServerAccessParamsDto, File manifestPath, S3FileTransferRequestParamsDto s3FileTransferRequestParamsDto) Executes the downloader workflow.

Methods inherited from class org.finra.herd.tools.common.databridge.DataBridgeController

adjustIntegerValue, getStorageNameFromManifest

Methods inherited from class java.lang.Object

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

Constructor Detail

DownloaderController

public DownloaderController()

Method Detail

performDownload

public void performDownload(RegServerAccessParamsDto regServerAccessParamsDto,
                            File manifestPath,
                            S3FileTransferRequestParamsDto s3FileTransferRequestParamsDto)
                     throws InterruptedException,
                            JAXBException,
                            IOException,
                            URISyntaxException

Executes the downloader workflow.

Parameters:

regServerAccessParamsDto - the DTO for the parameters required to communicate with the herd registration server

manifestPath - the local path to the manifest file

s3FileTransferRequestParamsDto - the S3 file transfer DTO request parameters

Throws:

InterruptedException - if the upload thread was interrupted.

JAXBException - if a JAXB error was encountered.

IOException - if an I/O error was encountered.

URISyntaxException - if a URI syntax error was encountered.

createDownloaderOutputManifestDto

protected DownloaderOutputManifestDto createDownloaderOutputManifestDto(BusinessObjectData businessObjectData,
                                                                        StorageUnit storageUnit,
                                                                        String s3KeyPrefix)

Creates a downloader output manifest instance from the business object data.

Parameters:

businessObjectData - the business object data that we need to create the manifest for

storageUnit - the S3 storage unit for this business object data

s3KeyPrefix - the S3 key prefix for this business object data

Returns:

the created downloader output manifest instance