public abstract class AbstractEventDrivenWFT<C extends ClientContext> extends AbstractClientWFT<C> implements RemoteTaskEventReceiver<C>
RemoteTaskEvent
s.childTaskRef, isTestMode, monitorController, resultRef, stateFlag
Constructor and Description |
---|
AbstractEventDrivenWFT(AbstractWorkflow<C> workflow) |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancels the remote counterpart task running on the server using a
RemoteTaskCancelAgent . |
void |
enterTask(WorkflowTask previousTask)
Runs in the ET before the task starts to run async
|
void |
executeAsyncImpl()
This method is executed asynchronously
|
protected RemoteTaskCreator |
getRemoteTaskCreator()
Should be overridden if a
RemoteTaskCreator is being used to instantiate the remote task. |
void |
receivedTaskEvent(RemoteTaskEvent event)
Is called whenever this task has received a
RemoteTaskEvent from the remotely running task. |
getClientConfig, getClientContext, getWorkspaceDir
executeAsync, exitTask, getTaskIndex, getWorkflow, getWorkingDir, isDeciderTask, isTaskRepeating, setName, setTaskIndex, updateTaskName
addMonitor, addTaskListener, awaitEventsDone, doneChildFinished, doneChildStarted, doneTaskCancelled, doneTaskFailed, doneTaskFinished, doneTaskProceeded, doneTaskStarted, doneTaskStateChanged, doneTaskSucceeded, getActionCancel, getRenderColor, getRenderIcon, getRenderText, getSwingTaskMonitor, isRegisterInTaskList, removeTaskListener, showError, showError, showError, showInfo, showInfo, showWarning, showWarning
awaitFinished, awaitFinished, awaitStarted, createTaskId, deregisterTask, doOnFinish, doOnStart, doOnSuccess, executeChildTask, executeChildTask, getCurrentFuture, getMaxChildTasks, getPriority, getProcessingDuration, getStartTime, getStopWatch, handleFinish, handleStart, handleSuccess, isRegisterForCancel, isRunning, notifyProceeded, registerTask, releaseStart, run, setCurrentFuture, setMaxChildTasks, setPriority, setRegisterForCancel, setReleaseTimeout, submit, submit, submitInternal, toString, wasSucceeded
checkCancelled, checkForErrorAndRethrow, clearMonitors, createRunStateFlag, doOnCancel, doOnFailure, execute, executeSubTask, getError, getMaxProgressSteps, getMonitorCount, getMonitors, getName, getProgressStepCount, getResult, getRunStateFlag, getTaskId, getType, handleCancellation, handleFailure, hasError, hasMonitor, isCancellable, registerTaskStateChange, removeMonitor, resetProgress, setCancellable, setLogLevel, setMaxProgressSteps, setMonitor, setName, setResult, setRunStateFlag, setTaskId, setType, shouldFireMonitor, sleepChecked, wasCancelled
getApplicationContext, getLogChannel, isLogDebug, isLogVerbose, logDebug, logDump, logError, logError, logFatal, logInfo, logVerbose, logWarning, setLogChannel
configureDumpHeadlineLength, configureDumpMaxElementsPrinted, copyDumpStringValues, copyToStringValues, createDumpHeader, toDumpString, toDumpString, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
awaitFinished, awaitFinished, awaitStarted, executeChildTask, executeChildTask, getError, getProcessingDuration, hasError, isRegisterForCancel, isRunning, releaseStart, setName, setReleaseTimeout, submit, submit
checkCancelled, checkForErrorAndRethrow, executeAsync, executeSubTask, getName, getResult, getRunStateFlag, getTaskId, getType, handleCancellation, handleFailure, isCancellable, notifyProceeded, setCancellable, setName, setResult, setRunStateFlag, sleepChecked
getApplicationContext
execute
addMonitor, clearMonitors, getMonitorCount, getMonitors, hasMonitor, removeMonitor
getLogChannel, isLogDebug, isLogVerbose, logDebug, logDump, logError, logError, logFatal, logInfo, logVerbose, logWarning, setLogChannel
wasCancelled
getTaskId
toDumpString, toDumpString, toString, toString
getClientContext
public AbstractEventDrivenWFT(AbstractWorkflow<C> workflow)
public void enterTask(WorkflowTask previousTask) throws java.lang.Exception
WorkflowTask
enterTask
in interface WorkflowTask<C extends ClientContext>
enterTask
in class AbstractWFT<C extends ClientContext>
java.lang.Exception
public final void executeAsyncImpl() throws java.lang.Exception
WorkflowTask
executeAsyncImpl
in interface WorkflowTask<C extends ClientContext>
executeAsyncImpl
in class AbstractWFT<C extends ClientContext>
java.lang.Exception
protected RemoteTaskCreator getRemoteTaskCreator()
RemoteTaskCreator
is being used to instantiate the remote task.public final void cancel()
RemoteTaskCancelAgent
.cancel
in interface LocalCancellableTask
cancel
in class AbstractAsyncTask<C extends ClientContext>
public void receivedTaskEvent(RemoteTaskEvent event)
RemoteTaskEvent
from the remotely running task. Within this
method we may investigate the event type and perform an appropriate reaction. Note that any RuntimeException
thrown here will not break the event iteration.receivedTaskEvent
in interface RemoteTaskEventReceiver<C extends ClientContext>
Copyright © 2014 EsprIT-Systems. All Rights Reserved.