From 94f163aec3dd23acd49e004a7545588d13ac213d Mon Sep 17 00:00:00 2001 From: Adam Rusinowski Date: Wed, 30 Oct 2024 10:12:36 +0100 Subject: [PATCH] fixed handling `QueueMonitor.purgeLogsOlderThanDays` in Purge command --- src/Command/PurgeCommand.php | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/src/Command/PurgeCommand.php b/src/Command/PurgeCommand.php index 7156410..d99b81e 100644 --- a/src/Command/PurgeCommand.php +++ b/src/Command/PurgeCommand.php @@ -73,18 +73,20 @@ public function execute(Arguments $args, ConsoleIo $io) return self::CODE_SUCCESS; } + $purgeLogsOlderThanDays = (int)Configure::read( + 'QueueMonitor.purgeLogsOlderThanDays', + self::DEFAULT_PURGE_DAYS_OLD + ); + $purgeToDate = $this->queueMonitoringService->getPurgeToDate( - (int)Configure::read( - 'QueueMonitor.purgeLogsOlderThanDays', - self::DEFAULT_PURGE_DAYS_OLD - ) + $purgeLogsOlderThanDays ); $this->log( "Purging queue logs older than {$purgeToDate->toDateTimeString()} UTC", LogLevel::INFO ); try { - $rowCount = $this->queueMonitoringService->purgeLogs(self::DEFAULT_PURGE_DAYS_OLD); + $rowCount = $this->queueMonitoringService->purgeLogs($purgeLogsOlderThanDays); $this->log( "Purged $rowCount queue messages older than {$purgeToDate->toDateTimeString()} UTC", LogLevel::INFO