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, WorkerAction, AutoCloseable

Direct Known Subclasses:

StoreMetadataObjectActionHandler, StoreObjectGroupActionPlugin

public abstract class StoreObjectActionHandler
extends ActionHandler

Constructor Summary

Constructors

Constructor	Description
StoreObjectActionHandler(StorageClientFactory storageClientFactory)

Method Summary

Modifier and Type	Method	Description
protected StoredInfoResult	storeObject(String strategyId, ObjectDescription description, ItemStatus itemStatus)	The function is used for retrieving ObjectGroup in workspace and storing metaData in storage offer
protected BulkObjectStoreResponse	storeObjects(String startegy, 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 result

Methods inherited from class fr.gouv.vitam.worker.core.handler.ActionHandler

checkMandatoryParameters, close, updateDetailItemStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface fr.gouv.vitam.worker.core.api.WorkerAction

checkMandatoryIOParameter, execute, executeList

Constructor Details

StoreObjectActionHandler

public StoreObjectActionHandler(StorageClientFactory storageClientFactory)

Method Details

storeObject

protected StoredInfoResult storeObject(String strategyId,
 ObjectDescription description,
 ItemStatus itemStatus)

The function is used for retrieving ObjectGroup in workspace and storing metaData in storage offer

Parameters:

strategyId - the object's storage strategy

description - the object description

itemStatus - item status

Returns:

StoredInfoResult

storeObjects

protected BulkObjectStoreResponse storeObjects(String startegy,
 BulkObjectStoreRequest bulkObjectStoreRequest)
                                        throws StorageNotFoundClientException,
StorageServerClientException,
StorageAlreadyExistsClientException

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 -