Package io.vertigo.stella.impl.master

Class MasterManagerImpl

java.lang.Object

io.vertigo.stella.impl.master.MasterManagerImpl

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.Component, io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Manager, MasterManager

public final class MasterManagerImpl
extends Object
implements MasterManager, io.vertigo.core.node.component.Activeable

Implémentation de workManager.

Author:

pchretien, npiedeloup

Constructor Summary

Constructors

Constructor	Description
MasterManagerImpl(String nodeId, Optional<Integer> pollFrequencyMs, MasterPlugin masterPlugin, io.vertigo.core.analytics.AnalyticsManager analyticsManager)	Constructeur.

Method Summary

Modifier and Type	Method	Description
void	checkDeadNodesAndWorkItems()
<W, R> WorkPromise<R>	process(W work, Class<? extends WorkEngine<W,R>> workEngineClass)	Exécution d'un travail de façon synchrone.
<W, R> void	schedule(W work, Class<? extends WorkEngine<W,R>> workEngineClass, WorkResultHandler<R> workResultHandler)	Lancement asynchrone d'un travail 'dès que possible'.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

MasterManagerImpl

@Inject
public MasterManagerImpl(String nodeId,
 Optional<Integer> pollFrequencyMs,
 MasterPlugin masterPlugin,
 io.vertigo.core.analytics.AnalyticsManager analyticsManager)

Constructeur.

Parameters:

masterPlugin - Optional plugin for work's distribution

Method Details

start

public void start()

Specified by:

start in interface io.vertigo.core.node.component.Activeable

stop

public void stop()

Specified by:

stop in interface io.vertigo.core.node.component.Activeable

process

public <W,
R> WorkPromise<R> process(W work,
 Class<? extends WorkEngine<W,R>> workEngineClass)

Exécution d'un travail de façon synchrone.

Specified by:

process in interface MasterManager

Type Parameters:

W - Type de Work (Travail)

R - Produit d'un work à l'issu de son exécution

Parameters:

work - Travail à exécuter

Returns:

result

schedule

public <W,
R> void schedule(W work,
 Class<? extends WorkEngine<W,R>> workEngineClass,
 WorkResultHandler<R> workResultHandler)

Description copied from interface: MasterManager

Lancement asynchrone d'un travail 'dès que possible'.

Specified by:

schedule in interface MasterManager

Type Parameters:

W - Type de Work (Travail)

R - Produit d'un work à l'issu de son exécution

Parameters:

work - Travail à exécuter

workResultHandler - Handler permettant un callback après exécution

checkDeadNodesAndWorkItems

public void checkDeadNodesAndWorkItems()