#220: Additional condition to move expired messages for DB queue

Author: zhuravljov

src/drivers/db/Queue.php

@@ -243,7 +243,7 @@ private function moveExpired()
             $this->db->createCommand()->update(
                 $this->tableName,
                 ['reserved_at' => null],
-                '[[reserved_at]] < :time - [[ttr]] and [[done_at]] is null',
+                '[[reserved_at]] < :time - [[ttr]] and [[reserved_at]] is not null and [[done_at]] is null',
                 [':time' => $this->reserveTime]
             )->execute();
         }