Package fr.gouv.vitam.worker.core.impl
Class AsyncWorkspaceTransfer
- java.lang.Object
-
- fr.gouv.vitam.worker.core.impl.AsyncWorkspaceTransfer
-
public class AsyncWorkspaceTransfer extends java.lang.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 workspaceIf 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
startTransfer(int queueSize)
void
transfer(WorkspaceQueue workspaceQueue)
void
waitEndOfTransfer()
Wait end of transfer.
-
-
-
Constructor Detail
-
AsyncWorkspaceTransfer
public AsyncWorkspaceTransfer(HandlerIO handlerAsyncIO)
-
-
Method Detail
-
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
-
-