Ensures that queues are instance of the scheduled task class

2018-04-11 18:58:29 -04:00
parent cb80b5ca69
commit afefa89466
1 changed files with 2 additions and 0 deletions
--- a/lib/Cron/Workers/SendingQueue/SendingQueue.php
+++ b/lib/Cron/Workers/SendingQueue/SendingQueue.php
@ -32,6 +32,8 @@ class SendingQueue {
  function process() {
    $this->enforceSendingAndExecutionLimits();
    foreach(self::getRunningQueues() as $queue) {
+      if(!$queue instanceof SendingTask) continue;
+
      $newsletter = $this->newsletter_task->getNewsletterFromQueue($queue);
      if(!$newsletter) {
        continue;