diff --git a/src/CakeConsumerHelperTrait.php b/src/CakeConsumerHelperTrait.php index f4194d2..8eb11a0 100644 --- a/src/CakeConsumerHelperTrait.php +++ b/src/CakeConsumerHelperTrait.php @@ -132,7 +132,7 @@ protected function redeliverMessages(): void $this->getContext()->getTable()->updateAll( [ 'delivery_id' => null, - 'redeliver' => true, + 'redelivered' => true, ], [ 'redeliver_after <' => time(),