public class ForkJoinWorkerResponseContext extends SyncCallableWorkerResponseContext
fulfilled, responseTypes
currentSignal, responseCallbacks, retRegIndexes, targetCtx, workerCount, workerDataChannels
Constructor and Description |
---|
ForkJoinWorkerResponseContext(WorkerExecutionContext targetCtx,
int joinTargetIp,
int joinVarReg,
int timeoutTargetIp,
int timeoutVarReg,
int workerCount,
int reqJoinCount,
Set<String> joinWorkerNames,
Map<String,String> channelNames) |
Modifier and Type | Method and Description |
---|---|
protected WorkerExecutionContext |
onError(WorkerSignal signal) |
protected WorkerExecutionContext |
onHalt(WorkerSignal signal) |
protected WorkerExecutionContext |
onHaltFinalized() |
protected void |
onMessage(WorkerSignal signal) |
protected WorkerExecutionContext |
onReturn(WorkerSignal signal) |
protected WorkerExecutionContext |
onTimeout(WorkerSignal signal) |
getCurrentSignal, getWorkerErrors, handleAlreadyFulfilled, initWorkerErrors, isFulfilled, isReturnable, isWorkersDone, onFinalizedError, onFulfillment, printError, printStoredErrors, propagateErrorToTarget, setAsFulfilled, setCurrentSignal, storeError
doFailCallbackNotify, doSuccessCallbackNotify, getWorkerDataChannel, joinTargetContextInfo, modifyDebugCommands, registerResponseCallback, signal
protected WorkerExecutionContext onReturn(WorkerSignal signal)
onReturn
in class SyncCallableWorkerResponseContext
protected void onMessage(WorkerSignal signal)
onMessage
in class SyncCallableWorkerResponseContext
protected WorkerExecutionContext onHalt(WorkerSignal signal)
onHalt
in class SyncCallableWorkerResponseContext
protected WorkerExecutionContext onError(WorkerSignal signal)
onError
in class SyncCallableWorkerResponseContext
protected WorkerExecutionContext onTimeout(WorkerSignal signal)
onTimeout
in class BaseWorkerResponseContext
protected WorkerExecutionContext onHaltFinalized()
Copyright © 2018 WSO2. All rights reserved.