diff --git a/notifications/trunk/batch/process_event_stack.php b/notifications/trunk/batch/process_event_stack.php index 15476c3577497cd68ae50ff7cf675f07f9d1f816..2c348204ccfe4478eda71f3c666d3dacccd0afa6 100755 --- a/notifications/trunk/batch/process_event_stack.php +++ b/notifications/trunk/batch/process_event_stack.php @@ -122,7 +122,8 @@ while ($state <> 'END') { $dbAbs = new Database(); $stmt = $dbAbs->query($query, array($user_id)); if($stmt->rowCount() > 0) { - $recipient = $dbAbs->fetchObject($user_id); + //$recipient = $dbAbs->fetchObject($user_id); + $recipient = $stmt->fetchObject(); $user_id = $recipient->user_id; $logger->write($user_id .' is the replacent', 'INFO'); $recipients[] = $recipient;