beforeHandle and afterHandle events

src/console/QueueBusController.php

@@ -20,6 +20,8 @@
  */
 class QueueBusController extends Controller
 {
+    const EVENT_BEFORE_HANDLE = 'beforeHandle';
+    const EVENT_AFTER_HANDLE = 'afterHandle';
     /**
      * @var mixed|QueueInterface
      */
@@ -83,6 +85,10 @@ protected function loop($queueName)
                 $id = ArrayHelper::getValue($job, 'id');
                 Console::output("New job ID#{$id}");
 
+                if(!$this->beforeHandle($job)) {
+                    continue;
+                };
+
                 try {
                     if ($this->forceDelete) {
                         $this->delete($job);
@@ -97,6 +103,7 @@ protected function loop($queueName)
                 } catch (\Exception $e) {
                     $this->onError($job, $e);
                 }
+                $this->afterHandle($job);
                 unset($id, $job);
             }
 
@@ -112,6 +119,19 @@ protected function loop($queueName)
         }
     }
 
+    /**
+     * @param $job
+     * @return mixed
+     */
+    protected function beforeHandle($job)
+    {
+        $event = new QueueBusEvent([
+            'job' => $job
+        ]);
+        $this->trigger(self::EVENT_BEFORE_HANDLE, $event);
+        return $event->isValid;
+    }
+
     /**
      * @param $job
      * @return mixed|string
@@ -130,6 +150,16 @@ protected function handle($job)
         $this->delete($job);
     }
 
+    /**
+     * @param $job
+     */
+    protected function afterHandle($job)
+    {
+        $this->trigger(self::EVENT_AFTER_HANDLE, new QueueBusEvent([
+            'job' => $job
+        ]));
+    }
+
     /**
      * @param $job
      */

src/console/QueueBusEvent.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace trntv\bus\console;
+use yii\base\Event;
+
+
+/**
+ * Class QueueBusEvent
+ * @package trntv\bus\console
+ * @author Eugene Terentev <eugene@terentev.net>
+ */
+class QueueBusEvent extends Event
+{
+    /**
+     * @var array
+     */
+    public $job;
+    /**
+     * @var bool
+     */
+    public $isValid = true;
+}