Package com.soffid.iam.sync.service

Interface TaskQueue

public interface TaskQueue

Service TaskQueue Cola de tareas pendientes de ejecución

Version:

$Revision: 1.1 $

Author:

$Author: u07286 $

Field Summary

Fields

Modifier and Type	Field	Description
static String	SERVICE_NAME

Method Summary

Modifier and Type	Method	Description
TaskHandler	addTask(TaskEntity newTask)	Operation addTask Cola de tareas pendientes de ejecución
void	addTask(TaskHandler newTask)	Operation addTask Cola de tareas pendientes de ejecución
void	cancelTask(long taskId, String hash)	Operation cancelTask Cola de tareas pendientes de ejecución
int	countErrorTasks(DispatcherHandler taskDispatcher)	Operation countErrorTasks Number of errored tasks
int	countTasks()	Operation countTasks Cola de tareas pendientes de ejecución
int	countTasks(DispatcherHandler taskDispatcher)	Operation countTasks Cola de tareas pendientes de ejecución
Map<String,com.soffid.iam.sync.engine.intf.DebugTaskResults>	debugTask(TaskHandler task)	Operation debugTask Executes a task.
void	expireTasks()	Operation expireTasks Cola de tareas pendientes de ejecución
TaskHandler	findTaskHandlerById(long taskId)	Operation findTaskHandlerById Cola de tareas pendientes de ejecución
TaskHandler	getNextPendingTask(DispatcherHandler taskDispatcher, TaskHandler previousTask)	Operation getNextPendingTask Cola de tareas pendientes de ejecución
TaskHandler	getPendingTask(DispatcherHandler taskDispatcher)	Operation getPendingTask Cola de tareas pendientes de ejecución
boolean	isBestServer()	Operation isBestServer
void	notifyTaskStatus(TaskHandler task, DispatcherHandler taskDispatcher, boolean bOK, String sReason, Throwable t)	Operation notifyTaskStatus Cola de tareas pendientes de ejecución
void	notifyTaskStatusNewTransaction(TaskHandler task, DispatcherHandler taskDispatcher, boolean bOK, String sReason, Throwable t)	Operation notifyTaskStatusNewTransaction Cola de tareas pendientes de ejecución
TaskHandler	peekTaskToPersist()	Operation peekTaskToPersist Cola de tareas pendientes de ejecución
void	persistTask(TaskHandler newTask)	Operation persistTask Cola de tareas pendientes de ejecución
Map<String,Exception>	processOBTask(TaskHandler task)	Operation processOBTask Cola de tareas pendientes de ejecución
void	pushTaskToPersist(TaskHandler newTask)	Operation pushTaskToPersist Cola de tareas pendientes de ejecución
void	registerServerInstance(String name, String url)	Operation registerServerInstance Registers a kubernetes sync server instance
void	removeTask(TaskEntity task)	Operation removeTask Cola de tareas pendientes de ejecución
void	updateServerInstanceTasks()	Operation updateServerInstanceTasks
void	updateTask(TaskEntity task)	Operation updateTask Cola de tareas pendientes de ejecución

Field Detail

SERVICE_NAME

static final String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

isBestServer

boolean isBestServer()
              throws es.caib.seycon.ng.exception.InternalErrorException

Operation isBestServer

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

addTask

TaskHandler addTask(TaskEntity newTask)
             throws es.caib.seycon.ng.exception.InternalErrorException,
                    es.caib.seycon.ng.exception.InternalErrorException

Operation addTask Cola de tareas pendientes de ejecución

Parameters:

newTask -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

findTaskHandlerById

TaskHandler findTaskHandlerById(long taskId)
                         throws es.caib.seycon.ng.exception.InternalErrorException,
                                es.caib.seycon.ng.exception.InternalErrorException

Operation findTaskHandlerById Cola de tareas pendientes de ejecución

Parameters:

taskId -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

getNextPendingTask

TaskHandler getNextPendingTask(DispatcherHandler taskDispatcher,
                               TaskHandler previousTask)
                        throws es.caib.seycon.ng.exception.InternalErrorException,
                               es.caib.seycon.ng.exception.InternalErrorException

Operation getNextPendingTask Cola de tareas pendientes de ejecución

Parameters:

taskDispatcher -

previousTask -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

getPendingTask

TaskHandler getPendingTask(DispatcherHandler taskDispatcher)
                    throws es.caib.seycon.ng.exception.InternalErrorException,
                           es.caib.seycon.ng.exception.InternalErrorException

Operation getPendingTask Cola de tareas pendientes de ejecución

Parameters:

taskDispatcher -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

peekTaskToPersist

TaskHandler peekTaskToPersist()
                       throws es.caib.seycon.ng.exception.InternalErrorException,
                              es.caib.seycon.ng.exception.InternalErrorException

Operation peekTaskToPersist Cola de tareas pendientes de ejecución

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

countErrorTasks

int countErrorTasks(DispatcherHandler taskDispatcher)
             throws es.caib.seycon.ng.exception.InternalErrorException,
                    es.caib.seycon.ng.exception.InternalErrorException

Operation countErrorTasks Number of errored tasks

Parameters:

taskDispatcher -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

countTasks

int countTasks()
        throws es.caib.seycon.ng.exception.InternalErrorException,
               es.caib.seycon.ng.exception.InternalErrorException

Operation countTasks Cola de tareas pendientes de ejecución

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

countTasks

int countTasks(DispatcherHandler taskDispatcher)
        throws es.caib.seycon.ng.exception.InternalErrorException,
               es.caib.seycon.ng.exception.InternalErrorException

Operation countTasks Cola de tareas pendientes de ejecución

Parameters:

taskDispatcher -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

debugTask

Map<String,com.soffid.iam.sync.engine.intf.DebugTaskResults> debugTask(TaskHandler task)
                                                                      throws es.caib.seycon.ng.exception.InternalErrorException,
                                                                             es.caib.seycon.ng.exception.InternalErrorException

Operation debugTask Executes a task. Returns a map with two attributes for each dispatcher: log and status

Parameters:

task -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

processOBTask

Map<String,Exception> processOBTask(TaskHandler task)
                                   throws es.caib.seycon.ng.exception.InternalErrorException,
                                          es.caib.seycon.ng.exception.InternalErrorException

Operation processOBTask Cola de tareas pendientes de ejecución

Parameters:

task -

Returns:

Throws:

es.caib.seycon.ng.exception.InternalErrorException

addTask

void addTask(TaskHandler newTask)
      throws es.caib.seycon.ng.exception.InternalErrorException,
             es.caib.seycon.ng.exception.InternalErrorException,
             es.caib.seycon.ng.exception.InternalErrorException

Operation addTask Cola de tareas pendientes de ejecución

Parameters:

newTask -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

cancelTask

void cancelTask(long taskId,
                String hash)
         throws es.caib.seycon.ng.exception.InternalErrorException,
                es.caib.seycon.ng.exception.InternalErrorException

Operation cancelTask Cola de tareas pendientes de ejecución

Parameters:

taskId -

hash -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

expireTasks

void expireTasks()
          throws es.caib.seycon.ng.exception.InternalErrorException,
                 es.caib.seycon.ng.exception.InternalErrorException,
                 es.caib.seycon.ng.exception.InternalErrorException

Operation expireTasks Cola de tareas pendientes de ejecución

Throws:

es.caib.seycon.ng.exception.InternalErrorException

notifyTaskStatus

void notifyTaskStatus(TaskHandler task,
                      DispatcherHandler taskDispatcher,
                      boolean bOK,
                      String sReason,
                      Throwable t)
               throws es.caib.seycon.ng.exception.InternalErrorException,
                      es.caib.seycon.ng.exception.InternalErrorException,
                      es.caib.seycon.ng.exception.InternalErrorException

Operation notifyTaskStatus Cola de tareas pendientes de ejecución

Parameters:

task -

taskDispatcher -

bOK -

sReason -

t -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

notifyTaskStatusNewTransaction

void notifyTaskStatusNewTransaction(TaskHandler task,
                                    DispatcherHandler taskDispatcher,
                                    boolean bOK,
                                    String sReason,
                                    Throwable t)
                             throws es.caib.seycon.ng.exception.InternalErrorException,
                                    es.caib.seycon.ng.exception.InternalErrorException,
                                    es.caib.seycon.ng.exception.InternalErrorException

Operation notifyTaskStatusNewTransaction Cola de tareas pendientes de ejecución

Parameters:

task -

taskDispatcher -

bOK -

sReason -

t -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

persistTask

void persistTask(TaskHandler newTask)
          throws es.caib.seycon.ng.exception.InternalErrorException,
                 es.caib.seycon.ng.exception.InternalErrorException

Operation persistTask Cola de tareas pendientes de ejecución

Parameters:

newTask -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

pushTaskToPersist

void pushTaskToPersist(TaskHandler newTask)
                throws es.caib.seycon.ng.exception.InternalErrorException,
                       es.caib.seycon.ng.exception.InternalErrorException

Operation pushTaskToPersist Cola de tareas pendientes de ejecución

Parameters:

newTask -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

registerServerInstance

void registerServerInstance(String name,
                            String url)
                     throws es.caib.seycon.ng.exception.InternalErrorException

Operation registerServerInstance Registers a kubernetes sync server instance

Parameters:

name -

url -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

removeTask

void removeTask(TaskEntity task)
         throws es.caib.seycon.ng.exception.InternalErrorException,
                es.caib.seycon.ng.exception.InternalErrorException

Operation removeTask Cola de tareas pendientes de ejecución

Parameters:

task -

Throws:

es.caib.seycon.ng.exception.InternalErrorException

updateServerInstanceTasks

void updateServerInstanceTasks()
                        throws es.caib.seycon.ng.exception.InternalErrorException

Operation updateServerInstanceTasks

Throws:

es.caib.seycon.ng.exception.InternalErrorException

updateTask

void updateTask(TaskEntity task)
         throws es.caib.seycon.ng.exception.InternalErrorException,
                es.caib.seycon.ng.exception.InternalErrorException

Operation updateTask Cola de tareas pendientes de ejecución

Parameters:

task -

Throws:

es.caib.seycon.ng.exception.InternalErrorException