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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description TaskHandler
addTask(TaskEntity newTask)
Operation addTask Cola de tareas pendientes de ejecuciónvoid
addTask(TaskHandler newTask)
Operation addTask Cola de tareas pendientes de ejecuciónvoid
cancelTask(long taskId, String hash)
Operation cancelTask Cola de tareas pendientes de ejecuciónint
countErrorTasks(DispatcherHandler taskDispatcher)
Operation countErrorTasks Number of errored tasksint
countTasks()
Operation countTasks Cola de tareas pendientes de ejecuciónint
countTasks(DispatcherHandler taskDispatcher)
Operation countTasks Cola de tareas pendientes de ejecuciónMap<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ónTaskHandler
findTaskHandlerById(long taskId)
Operation findTaskHandlerById Cola de tareas pendientes de ejecuciónTaskHandler
getNextPendingTask(DispatcherHandler taskDispatcher, TaskHandler previousTask)
Operation getNextPendingTask Cola de tareas pendientes de ejecuciónTaskHandler
getPendingTask(DispatcherHandler taskDispatcher)
Operation getPendingTask Cola de tareas pendientes de ejecuciónboolean
isBestServer()
Operation isBestServervoid
notifyTaskStatus(TaskHandler task, DispatcherHandler taskDispatcher, boolean bOK, String sReason, Throwable t)
Operation notifyTaskStatus Cola de tareas pendientes de ejecuciónvoid
notifyTaskStatusNewTransaction(TaskHandler task, DispatcherHandler taskDispatcher, boolean bOK, String sReason, Throwable t)
Operation notifyTaskStatusNewTransaction Cola de tareas pendientes de ejecuciónTaskHandler
peekTaskToPersist()
Operation peekTaskToPersist Cola de tareas pendientes de ejecuciónvoid
persistTask(TaskHandler newTask)
Operation persistTask Cola de tareas pendientes de ejecuciónMap<String,Exception>
processOBTask(TaskHandler task)
Operation processOBTask Cola de tareas pendientes de ejecuciónvoid
pushTaskToPersist(TaskHandler newTask)
Operation pushTaskToPersist Cola de tareas pendientes de ejecuciónvoid
registerServerInstance(String name, String url)
Operation registerServerInstance Registers a kubernetes sync server instancevoid
removeTask(TaskEntity task)
Operation removeTask Cola de tareas pendientes de ejecuciónvoid
updateServerInstanceTasks()
Operation updateServerInstanceTasksvoid
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
-
-