fr.gouv.vitam.processing.distributor.v2

Class ProcessDistributorImpl

java.lang.Object

fr.gouv.vitam.processing.distributor.v2.ProcessDistributorImpl

All Implemented Interfaces:

ProcessDistributor, AutoCloseable

public class ProcessDistributorImpl
extends Object
implements ProcessDistributor

The Process Distributor call the workers and intercept the response for manage a post actions step

 TODO P1:
 - handle listing of items through a limited arraylist (memory) and through iterative (async) listing from
 Workspace
 - handle result in FATAL mode from one distributed item to stop the distribution in FATAL mode (do not
 continue)
 - try to handle distribution on 1 or on many as the same loop (so using a default arrayList of 1)
 - handle error level using order in enum in ProcessResponse.getGlobalProcessStatusCode instead of manually comparing:
  
    for (final EngineResponse response : responses) {
       tempStatusCode = response.getStatus();
       if (statusCode.ordinal() > tempStatusCode.ordinal()) {
           statusCode = tempStatusCode;
       }
      if (statusCode.ordinal() > StatusCode.KO.ordinal()) {
           break;
       }
     }
  
 

Field Summary

Fields inherited from interface fr.gouv.vitam.processing.distributor.api.ProcessDistributor

DISTRIBUTOR_INDEX, ELEMENT_UNITS, EXCEPTION_MESSAGE, JSON_EXTENSION, NOLEVEL, OBJECTS_LIST_EMPTY, WORKER_CALL_EXCEPTION

Constructor Summary

Constructors

Constructor and Description
ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration) Empty constructor
ProcessDistributorImpl(IWorkerManager workerManager, ServerConfiguration serverConfiguration, ProcessDataAccess processDataAccess, ProcessDataManagement processDataManagement, WorkspaceClientFactory workspaceClientFactory, WorkerClientFactory workerClientFactory)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(String operationId) Get the current step if the processWorkflow corresponding to the operationId and update his pauseCancelAction parameter to be PauseOrCancelAction.ACTION_CANCEL WorkerTask check this parameter and can cancel the not yet running tasks
void	close()
ItemStatus	distribute(WorkerParameters workParams, Step step, String operationId, PauseRecover pauseRecover) Temporary method for distribution supporting multi-list
ProcessDataAccess	getProcessDataAccess()
ProcessDataManagement	getProcessDataManagement()
WorkerClientFactory	getWorkerClientFactory()
IWorkerManager	getWorkerManager()
WorkspaceClientFactory	getWorkspaceClientFactory()
boolean	pause(String operationId) Get the current step of the processWorkflow corresponding to the operationId and update his pauseCancelAction parameter to be PauseOrCancelAction.ACTION_PAUSE WorkerTask check this parameter and can pause the not yet running tasks

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessDistributorImpl

public ProcessDistributorImpl(IWorkerManager workerManager,
                              ServerConfiguration serverConfiguration)

Empty constructor

Parameters:

workerManager -

serverConfiguration -

ProcessDistributorImpl

public ProcessDistributorImpl(IWorkerManager workerManager,
                              ServerConfiguration serverConfiguration,
                              ProcessDataAccess processDataAccess,
                              ProcessDataManagement processDataManagement,
                              WorkspaceClientFactory workspaceClientFactory,
                              WorkerClientFactory workerClientFactory)

Method Detail

pause

public boolean pause(String operationId)

Description copied from interface: ProcessDistributor

Get the current step of the processWorkflow corresponding to the operationId and update his pauseCancelAction parameter to be PauseOrCancelAction.ACTION_PAUSE WorkerTask check this parameter and can pause the not yet running tasks

Specified by:

pause in interface ProcessDistributor

Parameters:

operationId - concerning operation id

Returns:

true if pause applied, false else

cancel

public boolean cancel(String operationId)

Description copied from interface: ProcessDistributor

Get the current step if the processWorkflow corresponding to the operationId and update his pauseCancelAction parameter to be PauseOrCancelAction.ACTION_CANCEL WorkerTask check this parameter and can cancel the not yet running tasks

Specified by:

cancel in interface ProcessDistributor

Parameters:

operationId - concerning operation id

Returns:

true if pause applied, false else

distribute

public ItemStatus distribute(WorkerParameters workParams,
                             Step step,
                             String operationId,
                             PauseRecover pauseRecover)

Temporary method for distribution supporting multi-list

Specified by:

distribute in interface ProcessDistributor

Parameters:

workParams - of type WorkerParameters

step - the execution step

operationId - the operation id

pauseRecover - prevent recover from pause action

Returns:

the final step status

close

public void close()

Specified by:

close in interface AutoCloseable

getProcessDataAccess

public ProcessDataAccess getProcessDataAccess()

Specified by:

getProcessDataAccess in interface ProcessDistributor

getProcessDataManagement

public ProcessDataManagement getProcessDataManagement()

Specified by:

getProcessDataManagement in interface ProcessDistributor

getWorkerManager

public IWorkerManager getWorkerManager()

Specified by:

getWorkerManager in interface ProcessDistributor

getWorkspaceClientFactory

public WorkspaceClientFactory getWorkspaceClientFactory()

Specified by:

getWorkspaceClientFactory in interface ProcessDistributor

getWorkerClientFactory

public WorkerClientFactory getWorkerClientFactory()

Specified by:

getWorkerClientFactory in interface ProcessDistributor