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

Class AsyncWorkspaceTransfer

java.lang.Object

fr.gouv.vitam.worker.core.impl.AsyncWorkspaceTransfer

public class AsyncWorkspaceTransfer
extends Object

Send asynchronously files to the workspace Manage double collection, one for managing completable waitMonitor as batch The scond collection is for WorkspaceQueue, information of files to be sent to the workspace

If an exception occurs when a completable waitMonitor try to execute a task, this exception will be saved and propagated when the method waitEndOfTransfer is called

Constructor Summary

Constructors

Constructor	Description
AsyncWorkspaceTransfer(HandlerIO handlerAsyncIO)

Method Summary

Modifier and Type	Method	Description
void	startTransfer(int queueSize)
void	transfer(WorkspaceQueue workspaceQueue)
void	waitEndOfTransfer()	Wait end of transfer.

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncWorkspaceTransfer

public AsyncWorkspaceTransfer(HandlerIO handlerAsyncIO)

Method Details

transfer

public void transfer(WorkspaceQueue workspaceQueue)
              throws WorkerspaceQueueException

Throws:

WorkerspaceQueueException

startTransfer

public void startTransfer(int queueSize)
                   throws WorkerspaceQueueException

Throws:

WorkerspaceQueueException

waitEndOfTransfer

public void waitEndOfTransfer()
                       throws WorkerspaceQueueException

Wait end of transfer. All Completable waitMonitor should be completed

Throws:

WorkerspaceQueueException