pkp#7105 Adding callable methods for queueing system to be used at to…

…ols/runScheduledTasks
henriqueramos · Jun 7, 2021 · fa59e76 · fa59e76
1 parent dd55249
commit fa59e76
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 7 deletions.
diff --git a/classes/core/PKPContainer.inc.php b/classes/core/PKPContainer.inc.php
@@ -97,6 +97,10 @@ function ($app) {
             }
         );
 
+        $this->singleton('pkpQueue', function ($app) {
+            return new PKPQueueProvider();
+        });
+
         Facade::setFacadeApplication($this);
     }
 

diff --git a/classes/core/PKPQueueProvider.inc.php b/classes/core/PKPQueueProvider.inc.php
@@ -24,14 +24,8 @@
 
 class PKPQueueProvider
 {
-    public function runJobsAtShutdown(): void
+    public function runQueuedJobs(): void
     {
-        $shouldRun = Config::getVar('queues', 'run_jobs_at_shutdown', false);
-
-        if (!$shouldRun) {
-            return;
-        }
-
         $job = PKPJobModel
             ::isavailable()
                 ->notexcedeedattempts()
@@ -60,6 +54,17 @@ public function runJobsAtShutdown(): void
         );
     }
 
+    public function runJobsAtShutdown(): void
+    {
+        $shouldRun = Config::getVar('queues', 'run_jobs_at_shutdown', false);
+
+        if (!$shouldRun) {
+            return;
+        }
+
+        $this->runQueuedJobs();
+    }
+
     public function register()
     {
         register_shutdown_function([$this, 'runJobsAtShutdown']);