diff --git a/source/eventy/engine.d b/source/eventy/engine.d index 9d1c138..cc96e3c 100644 --- a/source/eventy/engine.d +++ b/source/eventy/engine.d @@ -251,9 +251,8 @@ public final class Engine : Thread /* Lock the queue collection */ queueLock.lock(); - /* TODO: Check for duplicate queue */ - /* If no such queue exists (recursive mutex used) */ - if(findQueue(id)) + /* If no such queue exists then add it (recursive mutex used) */ + if(!findQueue(id)) { /* Add the queue */ queues ~= newQueue;