Public Member Functions | |
void | enroll (ILogger logger) |
this (ICluster cluster, int adminPort=0) | |
ICluster | getCluster () |
void | start () |
IConsumer | addConsumer (IPickleFactory task, bool enroll=false) |
Private Attributes | |
ILogger | logger |
ICluster | cluster |
HttpServer | adminServer |
import MyTask1, MyTask2, MyTask3; class MyTaskServer : TaskServer { this (char[] filename) { auto FileConduit config = new FileConduit (filename); ILogger logger = Logger.getLogger ("my.task.server"); super (new Cluster (logger, config)); } void enroll (ILogger logger) { addConsumer (new MyTask1); addConsumer (new MyTask2); addConsumer (new MyTask3); } } main () { MyTaskServer mts = new MyTaskServer ("cluster.properties"); mts.start (); }
Definition at line 95 of file TaskServer.d.
|
Referenced by start(). |
|
Definition at line 111 of file TaskServer.d. References ServletProvider::addContext(), adminServer, ICluster::getLogger(), and HttpServer. |
|
Definition at line 135 of file TaskServer.d. |
|
Definition at line 144 of file TaskServer.d. References adminServer, enroll(), and AbstractServer::start(). |
|
Definition at line 156 of file TaskServer.d. References IPickleFactory::getGuid(), ICluster::getLogger(), and ILogger::info(). |
|
Definition at line 97 of file TaskServer.d. |
|
Definition at line 98 of file TaskServer.d. |
|
Definition at line 99 of file TaskServer.d. |