Update MailQueue.php

nterms · Jan 18, 2016 · 5077f79 · 5077f79
1 parent d1452ef
commit 5077f79
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/MailQueue.php b/MailQueue.php
@@ -91,7 +91,7 @@ public function process()
 
 		$success = true;
 
-		$items = Queue::find()->where(['and', ['sent_time' => NULL], ['<', 'attempts', $this->maxAttempts]])->orderBy(['created_at' => SORT_ASC])->limit($this->mailsPerRound)->all();
+		$items = Queue::find()->where(['and', ['sent_time' => NULL], ['<', 'attempts', $this->maxAttempts], ['<=', 'time_to_send', date('Y-m-d H:i:s')]])->orderBy(['created_at' => SORT_ASC])->limit($this->mailsPerRound)->all();
 		// dd($items);
 		if(!empty($items)) {
 			foreach($items as $item) {
@@ -115,4 +115,4 @@ public function process()
 
 		return $success;
 	}
-}
+}