public class ClientTaskManager<C extends ClientContext> extends TaskManager<C> implements ClientObject<C>, JournalTaskRestarter<C>, JournalTaskRestartEvent.Source, Initializable
TaskManager
such that all activity lists are maintained
centrally here.Constructor and Description |
---|
ClientTaskManager(C clientCtx) |
Modifier and Type | Method and Description |
---|---|
void |
addTaskRestartListener(JournalTaskRestartEvent.Listener l) |
int |
cancelAll() |
void |
cancelAllRemoteActivity() |
boolean |
cancelTask(RemoteTaskId taskId,
SessionId sessId)
Sends a
RemoteTaskCancelAgent in order to cancel the remote task on the server. |
void |
checkInitialized()
Checks whether initialization has yet been done and throws
an
NotInitializedException if not. |
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
|
void |
fillCurrentActivity(java.util.Map<java.lang.String,java.lang.Integer> activityMap)
Stores the current item-count in the given activityMap.
|
ActiveAbosListModel |
getActiveAbosListModel() |
ActiveAgentsListModel |
getActiveAgentsListModel()
Returns a ListModel instance that maintains AgentId objects of the async agents that
are currently running on the server.
|
ActiveCommandsListModel |
getActiveCommandsListModel()
Returns a ListModel instance that maintains the currently running async client commands.
|
ActiveLocksListModel |
getActiveLocksListModel()
Returns the ResourceLockCache singleton instance.
|
ActiveStreamsListModel |
getActiveStreamsListModel()
Returns a ListModel instance that maintains JobId objects of the stream downloads that
are currently running.
|
ActiveTransfersListModel |
getActiveTransfersListModel()
Returns a ListModel instance that maintains JobId objects of the async file transfers that
are currently running.
|
C |
getClientContext()
Returns the the client runtime environment
|
JournalTaskRestarter<C> |
getJournalTaskRestarter() |
void |
init()
Performs the initialization of this class.
|
boolean |
isInitialized()
Tells whether initialization has yet been done.
|
AsyncTask |
reattachToJournalTask(java.lang.String serverName,
JournalTaskId taskId)
Is called for each remote journal task that has to be reattached.
|
void |
removeTaskRestartListener(JournalTaskRestartEvent.Listener l) |
void |
setJournalTaskRestarter(JournalTaskRestarter<C> journalTaskRestarter) |
cancelTask, checkForActivity, close, deregisterTask, findAllCancellableTaskIds, findAllNonCancellableTaskIds, findTask, findTaskByName, getActiveOsProcessesListModel, getActiveTasksListModel, getActiveWorkflowsListModel, getAsyncExecutor, getTaskCount, registerTask, registerTaskStateChange
getApplicationContext, getLogChannel, isLogDebug, isLogVerbose, logDebug, logDump, logError, logError, logFatal, logInfo, logVerbose, logWarning, setLogChannel
configureDumpHeadlineLength, configureDumpMaxElementsPrinted, copyDumpStringValues, copyToStringValues, createDumpHeader, toDumpString, toDumpString, toString, toString
public ClientTaskManager(C clientCtx)
public final C getClientContext()
ClientObject
getClientContext
in interface ClientObject<C extends ClientContext>
public int cancelAll()
cancelAll
in class TaskManager<C extends ClientContext>
public void cancelAllRemoteActivity()
public boolean cancelTask(RemoteTaskId taskId, SessionId sessId)
RemoteTaskCancelAgent
in order to cancel the remote task on the server.
The local counterpart task remains untouched but will react on the remote cancel.public void init()
Initializable
init
in interface Initializable
public boolean isInitialized()
Initializable
isInitialized
in interface Initializable
public void checkInitialized() throws NotInitializedException
Initializable
NotInitializedException
if not.checkInitialized
in interface Initializable
NotInitializedException
public void fillCurrentActivity(java.util.Map<java.lang.String,java.lang.Integer> activityMap)
TaskManager
fillCurrentActivity
in class TaskManager<C extends ClientContext>
public ActiveAgentsListModel getActiveAgentsListModel()
public ActiveTransfersListModel getActiveTransfersListModel()
public ActiveStreamsListModel getActiveStreamsListModel()
public ActiveCommandsListModel getActiveCommandsListModel()
public ActiveLocksListModel getActiveLocksListModel()
public ActiveAbosListModel getActiveAbosListModel()
public void setJournalTaskRestarter(JournalTaskRestarter<C> journalTaskRestarter)
public JournalTaskRestarter<C> getJournalTaskRestarter()
public void doBeforeJournalTaskRestart(java.lang.String serverName)
JournalTaskRestarter
doBeforeJournalTaskRestart
in interface JournalTaskRestarter<C extends ClientContext>
public AsyncTask reattachToJournalTask(java.lang.String serverName, JournalTaskId taskId) throws java.lang.Exception
JournalTaskRestarter
reattachToJournalTask
in interface JournalTaskRestarter<C extends ClientContext>
java.lang.Exception
public void doAfterJournalTaskRestart(java.lang.String serverName)
JournalTaskRestarter
doAfterJournalTaskRestart
in interface JournalTaskRestarter<C extends ClientContext>
public final void addTaskRestartListener(JournalTaskRestartEvent.Listener l)
addTaskRestartListener
in interface JournalTaskRestartEvent.Source
public final void removeTaskRestartListener(JournalTaskRestartEvent.Listener l)
removeTaskRestartListener
in interface JournalTaskRestartEvent.Source
Copyright © 2014 EsprIT-Systems. All Rights Reserved.