|
Errai 3.0.1-SNAPSHOT | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.errai.bus.server.WorkerFactory
public class WorkerFactory
The WorkerFactory maintains a pool of Workers, and takes care of running and terminating them
Constructor Summary | |
---|---|
WorkerFactory(ErraiService svc)
Initializes the worker factory with a new thread group, service, all the properties, messages and workers |
Method Summary | |
---|---|
void |
deliver(Message m)
Attempts to send the message |
void |
deliverGlobal(Message m)
Attempts to deliver the specified message globally |
protected BlockingQueue<Message> |
getMessages()
Gets the messages in the queue |
protected long |
getWorkerTimeout()
Gets the timeout |
void |
startPool()
Starts execution of all the threads in the pool of threads |
void |
stopPool()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public WorkerFactory(ErraiService svc)
svc
- - the ErraiService that is to be associated to this factory of workersMethod Detail |
---|
public void deliverGlobal(Message m) throws InterruptedException
m
- - message to be delivered
InterruptedException
public void deliver(Message m) throws InterruptedException
m
- - message to be sent
InterruptedException
protected BlockingQueue<Message> getMessages()
protected long getWorkerTimeout()
public void startPool()
public void stopPool()
|
Errai 3.0.1-SNAPSHOT | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |