delay processing of received simple pushes

1 files changed, 5 insertions, 0 deletions

diff --git a/Digitigrade/Job/ProcessIncomingPush.php b/Digitigrade/Job/ProcessIncomingPush.php
index eb6bdd5..600972c 100644
--- a/Digitigrade/Job/ProcessIncomingPush.php
+++ b/Digitigrade/Job/ProcessIncomingPush.php
@@ -2,6 +2,7 @@
 namespace Digitigrade\Job;
 
 use Digitigrade\Job;
+use Digitigrade\JobQueue;
 use Digitigrade\Logger;
 use Digitigrade\Model\Actor;
 use Digitigrade\Model\Interaction;
@@ -49,4 +50,8 @@ class ProcessIncomingPush extends Job {
                 throw new \RuntimeException('invalid object type: ' . $this->object->type);
         }
     }
+
+    public function submitDelayed(int $delaySecs) {
+        JobQueue::getInstance()->submitDelayed($this, $delaySecs);
+    }
 }
\ No newline at end of file