Package fr.gouv.vitam.worker.core.impl

Class WorkspaceBatchRunner

java.lang.Object

fr.gouv.vitam.worker.core.impl.WorkspaceBatchRunner

All Implemented Interfaces:

Runnable

public class WorkspaceBatchRunner
extends Object
implements Runnable

This task is responsible of sending files to the workspace

Constructor Summary

Constructors

Constructor	Description
WorkspaceBatchRunner(HandlerIO handlerAsyncIO, Executor executor, int queueSize)

Method Summary

Modifier and Type	Method	Description
void	join()	Wait end of workspace batch this method may be called only once
void	run()
void	start()	Start the workspace batch This method should be called only once
void	transfer(WorkspaceQueue workspaceQueue)	Enqueue element to be transferred to the workspace

Methods inherited from class java.lang.Object

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

Constructor Details

WorkspaceBatchRunner

public WorkspaceBatchRunner(HandlerIO handlerAsyncIO,
 Executor executor,
 int queueSize)

Method Details

run

public void run()

Specified by:

run in interface 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