Package fr.gouv.vitam.ingest.external.core

Class IngestExternalImpl

java.lang.Object

fr.gouv.vitam.ingest.external.core.IngestExternalImpl

All Implemented Interfaces:

IngestExternal

public class IngestExternalImpl
extends java.lang.Object
implements IngestExternal

Implementation of IngestExtern

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	INGEST_INT_UPLOAD

Constructor Summary

Constructors

Constructor	Description
IngestExternalImpl(IngestExternalConfiguration config, FormatIdentifierFactory formatIdentifierFactory, IngestInternalClientFactory ingestInternalClientFactory, ManifestDigestValidator manifestDigestValidator)

Method Summary

Modifier and Type	Method	Description
void	handleResponseWithATR(GUID operationId, javax.ws.rs.container.AsyncResponse asyncResponse, java.lang.String entity)
PreUploadResume	preUploadAndResume(java.io.InputStream input, java.lang.String workflowIdentifier, GUID guid, java.lang.String xAction, javax.ws.rs.container.AsyncResponse asyncResponse)
StatusCode	upload(PreUploadResume preUploadResume, java.lang.String xAction, GUID guid, java.lang.String manifestDigestValue, java.lang.String manifestDigestAlgo)	upload the file -- store in local, scan for viruses and then check for supported format (ZIP, TAR, ...)

Methods inherited from class java.lang.Object

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

Field Detail

INGEST_INT_UPLOAD

public static final java.lang.String INGEST_INT_UPLOAD

See Also:

Constant Field Values

Constructor Detail

IngestExternalImpl

public IngestExternalImpl(IngestExternalConfiguration config,
                          FormatIdentifierFactory formatIdentifierFactory,
                          IngestInternalClientFactory ingestInternalClientFactory,
                          ManifestDigestValidator manifestDigestValidator)

Method Detail

preUploadAndResume

public PreUploadResume preUploadAndResume(java.io.InputStream input,
                                          java.lang.String workflowIdentifier,
                                          GUID guid,
                                          java.lang.String xAction,
                                          javax.ws.rs.container.AsyncResponse asyncResponse)
                                   throws IngestExternalException,
                                          VitamClientException

Specified by:

preUploadAndResume in interface IngestExternal

Throws:

IngestExternalException

VitamClientException

upload

public StatusCode upload(PreUploadResume preUploadResume,
                         java.lang.String xAction,
                         GUID guid,
                         java.lang.String manifestDigestValue,
                         java.lang.String manifestDigestAlgo)
                  throws IngestExternalException

Description copied from interface: IngestExternal

upload the file -- store in local, scan for viruses and then check for supported format (ZIP, TAR, ...)

Specified by:

upload in interface IngestExternal

Parameters:

preUploadResume - informations returned

Returns:

Response containing as InputStream the ArchiveTransferReply in XML format

Throws:

IngestExternalException - thrown if an error occurred in workflow

handleResponseWithATR

public void handleResponseWithATR(GUID operationId,
                                  javax.ws.rs.container.AsyncResponse asyncResponse,
                                  java.lang.String entity)