org.thales.punch.apps.shiva.filesystem

Class FilesystemController

java.lang.Object

org.thales.punch.apps.shiva.filesystem.FilesystemController

All Implemented Interfaces:

IController

public class FilesystemController
extends Object
implements IController

This class has only one purpose : share the same producer between the worker and the leader.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
FilesystemController(String root, String commandTopic, String controlTopic, String assignementTopic)

Method Summary

Modifier and Type	Method and Description
void	startLeader(ILeader leader, long tickInterval) The leader is started in a dedicated thread but every time it vanishes, it is restarted from a fresh new state.
void	startWorker(IWorker worker, long tickInterval) A worker is started only once and is not supposed to vanish ever.

Methods inherited from class java.lang.Object

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

Constructor Detail

FilesystemController

public FilesystemController(String root,
                            String commandTopic,
                            String controlTopic,
                            String assignementTopic)
                     throws IOException

Throws:

IOException

Method Detail

startLeader

public void startLeader(ILeader leader,
                        long tickInterval)

The leader is started in a dedicated thread but every time it vanishes, it is restarted from a fresh new state.

Specified by:

startLeader in interface IController

Parameters:

leader - the leader

tickInterval - the refresh interval

startWorker

public void startWorker(IWorker worker,
                        long tickInterval)

A worker is started only once and is not supposed to vanish ever.

Specified by:

startWorker in interface IController

Parameters:

worker - the worker to start

tickInterval - the refresh interval