Package fr.gouv.vitam.processing.distributor.core

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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerFamilyManager

public WorkerFamilyManager(java.lang.String family,
                           int queueSize)

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()