Skip to content

Commit fa0c875

Browse files
committed
Merge pull request #12 from zledwon/master
use size param in getBatch()
2 parents cf347ca + f67800f commit fa0c875

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/Model/Table/EmailQueueTable.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,7 @@ public function getBatch($size = 10)
103103
$this->aliasField('send_at').' <=' => new FrozenTime('now'),
104104
$this->aliasField('locked') => false,
105105
])
106+
->limit($size)
106107
->order([$this->aliasField('created') => 'ASC']);
107108

108109
$emails

0 commit comments

Comments
 (0)