fr.gouv.vitam.processing.model

Class WorkerAsyncRequest

java.lang.Object

fr.gouv.vitam.processing.model.WorkerAsyncRequest

public class WorkerAsyncRequest
extends Object

Class for manage the launch of an "async" request

Constructor Summary

Constructors

Constructor and Description
WorkerAsyncRequest(DescriptionStep descriptionStep, Callbackable<WorkerAsyncResponse> callingProcess, Set<WorkerAsyncRequest> currentRunningObjectsInStep, String queueId, Semaphore waitingStepAllAsyncRequest, VitamSession session) Default constructor

Method Summary

Modifier and Type	Method and Description
void	callCallback(WorkerAsyncResponse workerAsyncResponse) call the callback at the end of the process
Thread	getCallerThread()
Set<WorkerAsyncRequest>	getCurrentRunningObjectsInStep()
DescriptionStep	getDescriptionStep() Arguments of the call
String	getQueueID()
VitamSession	getSession()
Semaphore	getWaitingStepAllAsyncRequest()

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerAsyncRequest

public WorkerAsyncRequest(DescriptionStep descriptionStep,
                          Callbackable<WorkerAsyncResponse> callingProcess,
                          Set<WorkerAsyncRequest> currentRunningObjectsInStep,
                          String queueId,
                          Semaphore waitingStepAllAsyncRequest,
                          VitamSession session)

Default constructor

Parameters:

descriptionStep - the step description

callingProcess - the callback

currentRunningObjectsInStep - the current object in step

queueId - the queue id

waitingStepAllAsyncRequest - the waiting step

session - the session id

Method Detail

getDescriptionStep

public DescriptionStep getDescriptionStep()

Arguments of the call

Returns:

the descriptionStep

callCallback

public void callCallback(WorkerAsyncResponse workerAsyncResponse)

call the callback at the end of the process

Parameters:

workerAsyncResponse - of type WorkerAsyncResponse

getCallerThread

public Thread getCallerThread()

Returns:

the Thread of the callerThread (ex: to interrupt it)

getCurrentRunningObjectsInStep

public Set<WorkerAsyncRequest> getCurrentRunningObjectsInStep()

Returns:

the currentRunningObjectsInStep

getQueueID

public String getQueueID()

Returns:

the queueID

getWaitingStepAllAsyncRequest

public Semaphore getWaitingStepAllAsyncRequest()

Returns:

the waitingStepAllAsyncRequest

getSession

public VitamSession getSession()

Returns:

the session