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

Class WorkerFamilyManager

java.lang.Object

fr.gouv.vitam.processing.distributor.core.WorkerFamilyManager

All Implemented Interfaces:

java.util.concurrent.Executor

public class WorkerFamilyManager
extends java.lang.Object
implements java.util.concurrent.Executor

Constructor Summary

Constructors

Constructor	Description
WorkerFamilyManager(java.lang.String family, int queueSize)

Method Summary

Modifier and Type	Method	Description
void	execute(java.lang.Runnable command)
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 -

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

getWorkers

public java.util.Map<java.lang.String,WorkerExecutor> getWorkers()

getFamily

public java.lang.String getFamily()