public final class ServerTaskManager extends TaskManager<ServerContext> implements ServerObject<ServerContext>, JournalTaskRestarter<ServerContext>, JournalTaskSupport
RemoteCancellableTask
instancesConstructor and Description |
---|
ServerTaskManager(ServerContext serverCtx) |
Modifier and Type | Method and Description |
---|---|
int |
cancelAllTasksOf(SessionId sessId)
Cancels all tasks of this session - except
JournalTask instances. |
boolean |
cancelRemoteTask(RemoteTaskId taskId,
SessionId killerId) |
void |
checkJournalTaskAlreadyRunning(java.lang.String taskName)
Note that
JournalTask s are recognized by name. |
void |
deregisterJournalTask(java.lang.String taskName) |
void |
deregisterTask(AsyncTask task) |
void |
doAfterJournalTaskRestart(java.lang.String serverName)
Is called after all remote journal tasks have been reattached
|
void |
doBeforeJournalTaskRestart(java.lang.String serverName)
Is called before the attempt to reattach to any remote journal tasks
|
JournalTaskId[] |
findJournalTaskIds() |
JournalTaskId[] |
findJournalTasksOnCoServers(java.lang.String... coServerNames)
Finds all currently running journal tasks on the given coServers.
|
java.util.List<RemoteTaskId> |
findRemoteTaskIds()
Returns the TaskIds of all currently running
RemoteTask s except those with JournalTaskId s. |
AsyncTask |
findTaskByName(java.lang.String taskName) |
JournalTaskRestarter<ServerContext> |
getJournalTaskRestarter() |
java.util.List<RemoteRunStateFlag> |
getLastReceivedRemoteRunStateFlags() |
ParallelStreamsList |
getParallelStreamsList() |
ParallelTransfersList |
getParallelTransfersList() |
ServerContext |
getServerContext()
Returns the server runtime environment
|
TaskHistoryWriter |
getTaskHistoryWriter() |
AsyncTask |
reattachToJournalTask(java.lang.String serverName,
JournalTaskId taskId)
Is called for each remote journal task that has to be reattached.
|
void |
registerForProgressEventsOnTask(SessionId sessionId,
TaskId myTaskId,
boolean doRegister) |
void |
registerTask(AsyncTask task) |
void |
setJournalTaskRestarter(JournalTaskRestarter<ServerContext> journalTaskRestarter) |
cancelAll, cancelTask, checkForActivity, close, fillCurrentActivity, findAllCancellableTaskIds, findAllNonCancellableTaskIds, findTask, getActiveOsProcessesListModel, getActiveTasksListModel, getActiveWorkflowsListModel, getAsyncExecutor, getTaskCount, registerTaskStateChange
getApplicationContext, getLogChannel, isLogDebug, isLogVerbose, logDebug, logDump, logError, logError, logFatal, logInfo, logVerbose, logWarning, setLogChannel
configureDumpHeadlineLength, configureDumpMaxElementsPrinted, copyDumpStringValues, copyToStringValues, createDumpHeader, toDumpString, toDumpString, toString, toString
public ServerTaskManager(ServerContext serverCtx)
public TaskHistoryWriter getTaskHistoryWriter()
public final ParallelTransfersList getParallelTransfersList()
public final ParallelStreamsList getParallelStreamsList()
public final ServerContext getServerContext()
ServerObject
getServerContext
in interface ServerObject<ServerContext>
public boolean cancelRemoteTask(RemoteTaskId taskId, SessionId killerId)
public java.util.List<RemoteTaskId> findRemoteTaskIds()
RemoteTask
s except those with JournalTaskId
s.public java.util.List<RemoteRunStateFlag> getLastReceivedRemoteRunStateFlags()
public void registerForProgressEventsOnTask(SessionId sessionId, TaskId myTaskId, boolean doRegister) throws java.lang.Exception
java.lang.Exception
public void registerTask(AsyncTask task)
registerTask
in class TaskManager<ServerContext>
public void deregisterTask(AsyncTask task)
deregisterTask
in class TaskManager<ServerContext>
public AsyncTask findTaskByName(java.lang.String taskName)
findTaskByName
in class TaskManager<ServerContext>
public JournalTaskId[] findJournalTaskIds()
public void deregisterJournalTask(java.lang.String taskName) throws java.lang.Exception
java.lang.Exception
public int cancelAllTasksOf(SessionId sessId)
JournalTask
instances.public void checkJournalTaskAlreadyRunning(java.lang.String taskName)
JournalTask
s are recognized by name. Therefore it is not allowed to run two equally named tasks at the same
time.public void setJournalTaskRestarter(JournalTaskRestarter<ServerContext> journalTaskRestarter)
public JournalTaskRestarter<ServerContext> getJournalTaskRestarter()
public void doBeforeJournalTaskRestart(java.lang.String serverName)
JournalTaskRestarter
doBeforeJournalTaskRestart
in interface JournalTaskRestarter<ServerContext>
public AsyncTask reattachToJournalTask(java.lang.String serverName, JournalTaskId taskId) throws java.lang.Exception
JournalTaskRestarter
reattachToJournalTask
in interface JournalTaskRestarter<ServerContext>
java.lang.Exception
public void doAfterJournalTaskRestart(java.lang.String serverName)
JournalTaskRestarter
doAfterJournalTaskRestart
in interface JournalTaskRestarter<ServerContext>
public JournalTaskId[] findJournalTasksOnCoServers(java.lang.String... coServerNames)
JournalTaskSupport
findJournalTasksOnCoServers
in interface JournalTaskSupport
Copyright © 2014 EsprIT-Systems. All Rights Reserved.