Skip to content

Commit 287b0b6

Browse files
committed
fixes
1 parent 4747256 commit 287b0b6

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

‎pkg/dbal/DbalConsumerHelperTrait.php‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ protected function fetchMessage(array $queues, int $redeliveryDelay): ?array
4848
->setParameter('redeliverAfter', $now + $redeliveryDelay, Type::BIGINT)
4949
;
5050

51-
while (microtime() < $endAt) {
51+
while (microtime(true) < $endAt) {
5252
$result = $select->execute()->fetch();
5353
if (empty($result)) {
5454
return null;
@@ -116,7 +116,6 @@ protected function removeExpiredMessages(): void
116116
->andWhere('(time_to_live IS NOT NULL) AND (time_to_live < :now)')
117117
->andWhere('(redelivered = false OR delivery_id IS NULL)')
118118
->setParameter(':now', (int) time(), Type::BIGINT)
119-
->setParameter('redelivered', false, Type::BOOLEAN)
120119
->execute()
121120
;
122121

0 commit comments

Comments
 (0)