diff --git a/mailpoet/lib/Cron/Workers/SendingQueue/SendingQueue.php b/mailpoet/lib/Cron/Workers/SendingQueue/SendingQueue.php index 8896ddc3bd..c1dcf7e980 100644 --- a/mailpoet/lib/Cron/Workers/SendingQueue/SendingQueue.php +++ b/mailpoet/lib/Cron/Workers/SendingQueue/SendingQueue.php @@ -258,12 +258,11 @@ class SendingQueue { } $foundSubscribers = $queryBuilder->getQuery()->getResult(); - $foundSubscribersIds = array_filter( - array_map(function(SubscriberEntity $subscriber) { - return (!empty($subscriber->getId())) ? $subscriber->getId() : false; - }, $foundSubscribers) - ); + $foundSubscribersIds = array_map(function(SubscriberEntity $subscriber) { + return $subscriber->getId(); + }, $foundSubscribers); } + // if some subscribers weren't found, remove them from the processing list if (count($foundSubscribersIds) !== count($subscribersToProcessIds)) { $subscribersToRemove = array_diff(