only add to queue if we are not waiting to start one..

diff --git a/Notify.php b/Notify.php
index 12ec3dd..46f7e8f 100644 (file)
--- a/Notify.php
+++ b/Notify.php
@@ -229,7 +229,8 @@ class Pman_Core_Notify extends Pman
         $pushed = array();
         $requeue = array();
         while (true) {
-            if ($w->fetch()) {
+            // only add if we don't have any queued up..
+            if (empty($ar) && $w->fetch()) {
                 $ar[] = clone($w);
                 $total--;
             }