Package fr.gouv.vitam.worker.core.plugin
Class StoreObjectActionHandler
java.lang.Object
fr.gouv.vitam.worker.core.handler.ActionHandler
fr.gouv.vitam.worker.core.plugin.StoreObjectActionHandler
- All Implemented Interfaces:
VitamAutoCloseable
,AutoCloseable
- Direct Known Subclasses:
StoreMetadataObjectActionHandler
,StoreObjectGroupActionPlugin
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected StoredInfoResult
storeObject
(HandlerIO handler, String strategyId, ObjectDescription description, ItemStatus itemStatus) The function is used for retrieving ObjectGroup in workspace and storing metaData in storage offerprotected BulkObjectStoreResponse
storeObjects
(HandlerIO handler, String strategy, BulkObjectStoreRequest bulkObjectStoreRequest) protected void
storeStorageInfos
(List<MapOfObjects> mapOfObjectsList, Map<String, BulkObjectStoreResponse> resultByStrategy, Map<String, String> strategiesByObjectId) protected void
updateSubTasksAndTasksFromStorageInfos
(Map<String, BulkObjectStoreResponse> resultsByStrategy, List<Map<String, ItemStatus>> itemStatusByObjectList, List<ItemStatus> itemStatusList) detailsFromStorageInfo, get storage details as JSON String from storageInfo resultMethods inherited from class fr.gouv.vitam.worker.core.handler.ActionHandler
checkMandatoryIOParameter, checkMandatoryParameters, close, execute, executeList, updateDetailItemStatus
-
Constructor Details
-
StoreObjectActionHandler
public StoreObjectActionHandler()
-
-
Method Details
-
storeObject
protected StoredInfoResult storeObject(HandlerIO handler, String strategyId, ObjectDescription description, ItemStatus itemStatus) The function is used for retrieving ObjectGroup in workspace and storing metaData in storage offer- Parameters:
handler
-strategyId
- the object's storage strategydescription
- the object descriptionitemStatus
- item status- Returns:
- StoredInfoResult
-
storeObjects
protected BulkObjectStoreResponse storeObjects(HandlerIO handler, String strategy, BulkObjectStoreRequest bulkObjectStoreRequest) throws StorageNotFoundClientException, StorageServerClientException, StorageAlreadyExistsClientException -
storeStorageInfos
protected void storeStorageInfos(List<MapOfObjects> mapOfObjectsList, Map<String, BulkObjectStoreResponse> resultByStrategy, Map<String, String> strategiesByObjectId) -
updateSubTasksAndTasksFromStorageInfos
protected void updateSubTasksAndTasksFromStorageInfos(Map<String, BulkObjectStoreResponse> resultsByStrategy, List<Map<String, ItemStatus>> itemStatusByObjectList, List<ItemStatus> itemStatusList) detailsFromStorageInfo, get storage details as JSON String from storageInfo result- Parameters:
resultsByStrategy
-itemStatusByObjectList
-itemStatusList
-
-