Class WorkerFamilyManager
- java.lang.Object
-
- fr.gouv.vitam.processing.distributor.core.WorkerFamilyManager
-
public class WorkerFamilyManager extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description WorkerFamilyManager(java.lang.String family, int queueSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.concurrent.Executor
getExecutor(boolean isHighPriorityTask)
java.lang.String
getFamily()
java.util.Map<java.lang.String,WorkerExecutor>
getWorkers()
void
registerWorker(WorkerBean workerBean)
void
unregisterWorker(java.lang.String workerId)
-
-
-
Method Detail
-
registerWorker
public void registerWorker(WorkerBean workerBean)
-
unregisterWorker
public void unregisterWorker(java.lang.String workerId)
- Parameters:
workerId
- the id of worker to unregister
-
getExecutor
public java.util.concurrent.Executor getExecutor(boolean isHighPriorityTask)
-
getWorkers
public java.util.Map<java.lang.String,WorkerExecutor> getWorkers()
-
getFamily
public java.lang.String getFamily()
-
-