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 Object
implements IngestExternal

Implementation of IngestExtern

Field Summary

Fields

Modifier and Type	Field and Description
static String	INGEST_INT_UPLOAD

Constructor Summary

Constructors

Constructor and Description
IngestExternalImpl(IngestExternalConfiguration config) Constructor IngestExternalImpl with parameter IngestExternalConfi guration
IngestExternalImpl(IngestExternalConfiguration config, FormatIdentifierFactory formatIdentifierFactory, IngestInternalClientFactory ingestInternalClientFactory)

Method Summary

Modifier and Type	Method and Description
void	createATRFatalWorkspace(String workflowIdentifier, String typeProcess, GUID operationId, javax.ws.rs.container.AsyncResponse asyncResponse) This method is called when a workspace exception occurs
void	handleResponseWithATR(GUID operationId, javax.ws.rs.container.AsyncResponse asyncResponse, String entity)
PreUploadResume	preUploadAndResume(InputStream input, String workflowIdentifier, GUID guid, javax.ws.rs.container.AsyncResponse asyncResponse)
StatusCode	upload(PreUploadResume preUploadResume, String xAction, GUID guid) 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 String INGEST_INT_UPLOAD

See Also:

Constant Field Values

Constructor Detail

IngestExternalImpl

public IngestExternalImpl(IngestExternalConfiguration config)

Constructor IngestExternalImpl with parameter IngestExternalConfi guration

Parameters:

config -

IngestExternalImpl

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

Method Detail

preUploadAndResume

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

Specified by:

preUploadAndResume in interface IngestExternal

Returns:

PreUploadResume

Throws:

WorkspaceClientServerException - error when workspace server is down

IngestExternalException

VitamClientException

upload

public StatusCode upload(PreUploadResume preUploadResume,
                         String xAction,
                         GUID guid)
                  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

createATRFatalWorkspace

public void createATRFatalWorkspace(String workflowIdentifier,
                                    String typeProcess,
                                    GUID operationId,
                                    javax.ws.rs.container.AsyncResponse asyncResponse)
                             throws VitamException

This method is called when a workspace exception occurs

Parameters:

workflowIdentifier -

typeProcess -

operationId -

asyncResponse -

Throws:

VitamException

handleResponseWithATR

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