fr.gouv.vitam.processing.distributor.v2

Class WorkerFamilyManager

java.lang.Object

fr.gouv.vitam.processing.distributor.v2.WorkerFamilyManager

All Implemented Interfaces:

Executor

public class WorkerFamilyManager
extends Object
implements Executor

Constructor Summary

Constructors

Constructor and Description
WorkerFamilyManager(int queueSize)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command)
Map<String,WorkerExecutor>	getWorkers()
void	registerWorker(WorkerBean workerBean)
void	unregisterWorker(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(int queueSize)

Method Detail

registerWorker

public void registerWorker(WorkerBean workerBean)

unregisterWorker

public void unregisterWorker(String workerId)

Parameters:

workerId -

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

getWorkers

public Map<String,WorkerExecutor> getWorkers()