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

…ols/runScheduledTasks
henriqueramos · Feb 17, 2022 · 314d253 · 314d253
1 parent 5d6f34f
commit 314d253
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/classes/core/PKPContainer.inc.php b/classes/core/PKPContainer.inc.php
@@ -113,6 +113,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,7 +24,7 @@
 
 class PKPQueueProvider
 {
-    public function runJobsAtShutdown(): void
+    public function runQueuedJobs(): void
     {
         $disableRun = Config::getVar('queues', 'disable_jobs_run_at_shutdown', false);
 
@@ -62,6 +62,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']);