Package fr.gouv.vitam.worker.core.impl
Class WorkspaceBatchRunner
- java.lang.Object
-
- fr.gouv.vitam.worker.core.impl.WorkspaceBatchRunner
-
- All Implemented Interfaces:
java.lang.Runnable
public class WorkspaceBatchRunner extends java.lang.Object implements java.lang.Runnable
This task is responsible of sending files to the workspace
-
-
Constructor Summary
Constructors Constructor Description WorkspaceBatchRunner(HandlerIO handlerAsyncIO, java.util.concurrent.Executor executor, int queueSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
join()
Wait end of workspace batch this method may be called only oncevoid
run()
void
start()
Start the workspace batch This method should be called only oncevoid
transfer(WorkspaceQueue workspaceQueue)
Enqueue element to be transferred to the workspace
-
-
-
Constructor Detail
-
WorkspaceBatchRunner
public WorkspaceBatchRunner(HandlerIO handlerAsyncIO, java.util.concurrent.Executor executor, int queueSize)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
transfer
public void transfer(WorkspaceQueue workspaceQueue) throws WorkerspaceQueueException
Enqueue element to be transferred to the workspace- Parameters:
workspaceQueue
-- Throws:
ProcessingException
WorkerspaceQueueException
-
start
public void start() throws WorkerspaceQueueException
Start the workspace batch This method should be called only once- Throws:
WorkerspaceQueueException
-
join
public void join() throws WorkerspaceQueueException
Wait end of workspace batch this method may be called only once- Throws:
WorkerspaceQueueException
-
-