public abstract class AbstractFileStreamWFT<C extends ClientContext> extends AbstractClientWFT<C>
FileStreamDownloadAgent
with the FileStreamJob
set.childTaskRef, isTestMode, monitorController, resultRef, stateFlag
Constructor and Description |
---|
AbstractFileStreamWFT(AbstractWorkflow workflow) |
Modifier and Type | Method and Description |
---|---|
protected void |
doneTaskFinished(TaskEvent e) |
protected void |
doneTaskProceeded(TaskEvent e) |
protected void |
doOnFinish()
Is called in ANY CASE when the task has finished.
|
void |
enterTask(WorkflowTask previousTask)
Runs in the ET before the task starts to run async
|
void |
executeAsyncImpl()
This method is executed asynchronously
|
FileDataType |
getFileDataType() |
FileStreamJob |
getJob() |
JobId |
getJobId() |
RemoteFileInfo |
getRemoteFileInfo() |
protected void |
readAsciiStream(DownloadReader reader) |
protected void |
readBinaryStream(DownloadStream stream) |
void |
setJob(FileStreamJob job) |
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, doneTaskStarted, doneTaskStateChanged, doneTaskSucceeded, getActionCancel, getRenderColor, getRenderIcon, getRenderText, getSwingTaskMonitor, isRegisterInTaskList, removeTaskListener, showError, showError, showError, showInfo, showInfo, showWarning, showWarning
awaitFinished, awaitFinished, awaitStarted, cancel, createTaskId, deregisterTask, 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
cancel
wasCancelled
getTaskId
toDumpString, toDumpString, toString, toString
public AbstractFileStreamWFT(AbstractWorkflow 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 RemoteFileInfo getRemoteFileInfo()
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 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 void doOnFinish()
AbstractAsyncTask
doOnFinish
in class AbstractAsyncTask<C extends ClientContext>
protected void doneTaskProceeded(TaskEvent e)
doneTaskProceeded
in class AbstractSwingTask<C extends ClientContext>
protected void doneTaskFinished(TaskEvent e)
doneTaskFinished
in class AbstractSwingTask<C extends ClientContext>
public void setTransferLocked(boolean isLocked)
public void setJob(FileStreamJob job)
public FileStreamJob getJob()
public FileDataType getFileDataType()
public JobId getJobId()
protected void readBinaryStream(DownloadStream stream) throws java.lang.Exception
java.lang.Exception
protected void readAsciiStream(DownloadReader reader) throws java.lang.Exception
java.lang.Exception
Copyright © 2014 EsprIT-Systems. All Rights Reserved.