From e9d83dbd244aeb1faf8fc2e06acfdb7c1b9d838e Mon Sep 17 00:00:00 2001
From: Alan Knowles <alan@roojs.com>
Date: Thu, 20 Aug 2015 10:45:12 +0800
Subject: [PATCH] Notify.php

---
 Notify.php | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/Notify.php b/Notify.php
index d6e70a69..984a8abf 100644
--- a/Notify.php
+++ b/Notify.php
@@ -204,7 +204,7 @@ class Pman_Core_Notify extends Pman
         $w->autoJoin();
         
         
-        $ar = $w->fetchAll();
+        $ar = array(); // $w->fetchAll();
         
         if (!empty($opts['list'])) {
             if (empty($ar)) {
@@ -224,7 +224,9 @@ class Pman_Core_Notify extends Pman
         $pushed = array();
         $requeue = array();
         while (true) {
-            
+            if ($w->fetch()) {
+                $ar[] = clone($w);
+            }
             
             $this->logecho("BATCH SIZE: ".  count($ar) );
             
-- 
2.39.2