diff options
author | Joas Schilling <coding@schilljs.com> | 2024-03-19 08:59:46 +0100 |
---|---|---|
committer | Joas Schilling <coding@schilljs.com> | 2024-03-19 09:01:35 +0100 |
commit | f63c8a212282d64351eb2825b0aeba210962b275 (patch) | |
tree | 29964d9803b8b9731125835164567e8978dd8483 /lib | |
parent | 52a49adf11a0d57bf4e8a031fe9e01f3f1b82033 (diff) |
fix(federation): Fix expiration of cached messages
Signed-off-by: Joas Schilling <coding@schilljs.com>
Diffstat (limited to 'lib')
-rw-r--r-- | lib/Model/ProxyCacheMessageMapper.php | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/Model/ProxyCacheMessageMapper.php b/lib/Model/ProxyCacheMessageMapper.php index f4fba2b24..f7006a13e 100644 --- a/lib/Model/ProxyCacheMessageMapper.php +++ b/lib/Model/ProxyCacheMessageMapper.php @@ -75,8 +75,8 @@ class ProxyCacheMessageMapper extends QBMapper { public function deleteExpiredMessages(\DateTimeInterface $dateTime): int { $query = $this->db->getQueryBuilder(); $query->delete($this->getTableName()) - ->where($query->expr()->isNotNull('expire_datetime')) - ->andWhere($query->expr()->lte('expire_datetime', $query->createNamedParameter($dateTime, IQueryBuilder::PARAM_DATE))); + ->where($query->expr()->isNotNull('expiration_datetime')) + ->andWhere($query->expr()->lte('expiration_datetime', $query->createNamedParameter($dateTime, IQueryBuilder::PARAM_DATE))); return $query->executeStatement(); } |