mirror of https://github.com/deavmi/tasky.git
Forgot to add the Queue for the Task's typeID to the Eventy Engine
This commit is contained in:
parent
b27a7cca55
commit
ff372498cf
|
@ -133,6 +133,7 @@ public final class TaskManager : Thread
|
||||||
/* Get the Event for dispatching */
|
/* Get the Event for dispatching */
|
||||||
Event dispatchEvent = job.getEventForDispatch();
|
Event dispatchEvent = job.getEventForDispatch();
|
||||||
|
|
||||||
|
|
||||||
writeln("Tasky: Job is fulfilled ", job);
|
writeln("Tasky: Job is fulfilled ", job);
|
||||||
|
|
||||||
/* Dispatch the event */
|
/* Dispatch the event */
|
||||||
|
@ -242,6 +243,10 @@ public final class TaskManager : Thread
|
||||||
{
|
{
|
||||||
Signal signalHandler = new Signal([typeID], handler);
|
Signal signalHandler = new Signal([typeID], handler);
|
||||||
eventEngine.addSignalHandler(signalHandler);
|
eventEngine.addSignalHandler(signalHandler);
|
||||||
|
|
||||||
|
/* Because this happens at the same time and a queue for this type would exist add that too */
|
||||||
|
/* TODO: Make eventy crash if typeID for non-existent queue */
|
||||||
|
eventEngine.addQueue(typeID);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue