Package fr.gouv.vitam.worker.core.impl
Class WorkerImpl
- java.lang.Object
-
- fr.gouv.vitam.worker.core.impl.WorkerImpl
-
- All Implemented Interfaces:
VitamAutoCloseable
,Worker
,java.lang.AutoCloseable
public class WorkerImpl extends java.lang.Object implements Worker
WorkerImpl class implements Worker interfacemanages and executes actions by step
-
-
Constructor Summary
Constructors Constructor Description WorkerImpl(PluginLoader pluginLoader)
Constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description WorkerImpl
addActionHandler(java.lang.String actionName, ActionHandler actionHandler)
Add an actionhandler in the pool of actionvoid
close()
java.lang.String
getWorkerId()
get Worker IdItemStatus
run(WorkerParameters workParams, Step step)
Worker execute the step's actions
-
-
-
Constructor Detail
-
WorkerImpl
public WorkerImpl(PluginLoader pluginLoader)
Constructor- Parameters:
pluginLoader
- the plugin loader
-
-
Method Detail
-
addActionHandler
public WorkerImpl addActionHandler(java.lang.String actionName, ActionHandler actionHandler)
Add an actionhandler in the pool of action- Specified by:
addActionHandler
in interfaceWorker
- Parameters:
actionName
- action nameactionHandler
- action handler- Returns:
- WorkerImpl
-
run
public ItemStatus run(WorkerParameters workParams, Step step) throws java.lang.IllegalArgumentException, ProcessingException
Description copied from interface:Worker
Worker execute the step's actions- Specified by:
run
in interfaceWorker
- Parameters:
workParams
-WorkerParameters
(one and only workItem will be in workParams)step
-Step
null not allowed- Returns:
- List EngineResponse
EngineResponse
: list of action response {OK,KO,FATAL...} - Throws:
java.lang.IllegalArgumentException
- throws when arguments are nullProcessingException
- throws when error in execution
-
getWorkerId
public java.lang.String getWorkerId()
Description copied from interface:Worker
get Worker Id- Specified by:
getWorkerId
in interfaceWorker
- Returns:
- id
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceVitamAutoCloseable
-
-