public abstract class AbstractFileTransferWFT<C extends ClientContext,S extends ServerContext> extends AbstractClientWFT<C>
childTaskRef, isTestMode, monitorController, resultRef, stateFlag
Constructor and Description |
---|
AbstractFileTransferWFT(AbstractWorkflow workflow,
java.lang.String taskName) |
Modifier and Type | Method and Description |
---|---|
void |
addJob(FileTransferJob job)
Adds a
FileTransferJob to the underlying FileTransferAgent |
void |
cancel()
Flags the task as being cancelled.
|
void |
clearJobs() |
protected FileTransferAgent<C,S> |
createFileTransferAgent() |
void |
enterTask(WorkflowTask previousTask)
Runs in the ET before the task starts to run async
|
void |
executeAsyncImpl()
This method is executed asynchronously
|
FileTransferAgent<C,S> |
getAgent() |
int |
getJobCount() |
java.util.List<FileTransferJob> |
getJobList() |
void |
setTransferLocked(boolean isLocked) |
TaskId |
submit(java.util.concurrent.ExecutorService pool)
Submits this task for execution to the given thread pool
|
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, 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
checkCancelled, checkForErrorAndRethrow, executeSubTask, getName, getResult, getRunStateFlag, getTaskId, getType, handleCancellation, handleFailure, isCancellable, notifyProceeded, setCancellable, 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
public AbstractFileTransferWFT(AbstractWorkflow workflow, java.lang.String taskName)
public FileTransferAgent<C,S> getAgent()
protected FileTransferAgent<C,S> createFileTransferAgent()
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 void executeAsyncImpl() throws java.lang.Exception
WorkflowTask
executeAsyncImpl
in interface WorkflowTask<C extends ClientContext>
executeAsyncImpl
in class AbstractWFT<C extends ClientContext>
java.lang.Exception
public void setTransferLocked(boolean isLocked)
public TaskId submit(java.util.concurrent.ExecutorService pool) throws java.lang.Exception
AsyncTask
submit
in interface AsyncTask<C extends ClientContext>
submit
in class AbstractAsyncTask<C extends ClientContext>
java.lang.Exception
- if the pool is busypublic void addJob(FileTransferJob job)
FileTransferJob
to the underlying FileTransferAgent
public int getJobCount()
public void clearJobs()
public java.util.List<FileTransferJob> getJobList()
public void cancel()
AbstractAsyncTask
AbstractAsyncExecutable.checkCancelled()
will
result a CancellationException
being thrown. As a result
AbstractAsyncExecutable.doOnCancel()
is being called on the task.cancel
in interface LocalCancellableTask
cancel
in class AbstractAsyncTask<C extends ClientContext>
Copyright © 2013 EsprIT-Systems. All Rights Reserved.