Skip to content

Commit b41e790

Browse files
committed
#977 - swap redelivered flag from in-line sql constant to parameter to better work with MS-SQL server
1 parent 339c7d2 commit b41e790

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

DbalConsumerHelperTrait.php

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,9 +129,10 @@ protected function removeExpiredMessages(): void
129129
->delete($this->getContext()->getTableName())
130130
->andWhere('(time_to_live IS NOT NULL) AND (time_to_live < :now)')
131131
->andWhere('delivery_id IS NULL')
132-
->andWhere('redelivered = false')
132+
->andWhere('redelivered = :redelivered')
133133

134134
->setParameter(':now', time(), Type::BIGINT)
135+
->setParameter('redelivered', false, Type::BOOLEAN)
135136
;
136137

137138
try {

0 commit comments

Comments
 (0)