Class ProcessDistributorImpl
java.lang.Object
fr.gouv.vitam.processing.distributor.core.ProcessDistributorImpl
- All Implemented Interfaces:
ProcessDistributor
The Process Distributor call the workers and intercept the response for manage a post actions step
- 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:
-
Field Summary
Fields inherited from interface fr.gouv.vitam.processing.distributor.api.ProcessDistributor
ELEMENT_UNITS, EXCEPTION_MESSAGE, JSON_EXTENSION, NOLEVEL, OBJECTS_LIST_EMPTY
-
Constructor Summary
ConstructorsConstructorDescriptionProcessDistributorImpl
(IWorkerManager workerManager, AsyncResourcesMonitor asyncResourcesMonitor, AsyncResourceCleaner asyncResourceCleaner, ServerConfiguration serverConfiguration) Empty constructorProcessDistributorImpl
(IWorkerManager workerManager, AsyncResourcesMonitor asyncResourcesMonitor, AsyncResourceCleaner asyncResourceCleaner, ServerConfiguration serverConfiguration, ProcessDataManagement processDataManagement, WorkspaceClientFactory workspaceClientFactory, MetaDataClientFactory metaDataClientFactory, WorkerClientFactory workerClientFactory) -
Method Summary
Modifier and TypeMethodDescriptiondistribute
(WorkerParameters workParams, Step step, String operationId) Temporary method for distribution supporting multi-list
-
Constructor Details
-
ProcessDistributorImpl
public ProcessDistributorImpl(IWorkerManager workerManager, AsyncResourcesMonitor asyncResourcesMonitor, AsyncResourceCleaner asyncResourceCleaner, ServerConfiguration serverConfiguration) Empty constructor- Parameters:
workerManager
- a WorkerManager instanceserverConfiguration
- distributor server configuration
-
ProcessDistributorImpl
public ProcessDistributorImpl(IWorkerManager workerManager, AsyncResourcesMonitor asyncResourcesMonitor, AsyncResourceCleaner asyncResourceCleaner, ServerConfiguration serverConfiguration, ProcessDataManagement processDataManagement, WorkspaceClientFactory workspaceClientFactory, MetaDataClientFactory metaDataClientFactory, WorkerClientFactory workerClientFactory)
-
-
Method Details
-
distribute
Temporary method for distribution supporting multi-list- Specified by:
distribute
in interfaceProcessDistributor
- Parameters:
workParams
- of typeWorkerParameters
step
- the execution stepoperationId
- the operation id- Returns:
- the final step status
-
getProcessDataManagement
- Specified by:
getProcessDataManagement
in interfaceProcessDistributor
-