fixed handling QueueMonitor.purgeLogsOlderThanDays in Purge command

CakeDC · Oct 30, 2024 · 94f163a · 94f163a
1 parent 1dc7b9d
commit 94f163a
Showing 1 changed file with 7 additions and 5 deletions.
diff --git 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