QueuedCommandMiddleware::delay

algsupport · Jan 28, 2016 · e31ea65 · e31ea65
1 parent 3b2764b
commit e31ea65
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/middlewares/QueuedCommandMiddleware.php b/src/middlewares/QueuedCommandMiddleware.php
@@ -28,6 +28,10 @@ class QueuedCommandMiddleware extends Object implements Middleware
      * @var string
      */
     public $defaultQueueName;
+    /**
+     * @var string
+     */
+    public $delay = 0;
 
     /**
      * @throws \yii\base\InvalidConfigException
@@ -60,7 +64,8 @@ public function execute($command, callable $next)
                     'serializer' => $this->serializer,
                     'object' => call_user_func($this->serializer[0], $command)
                 ],
-                $queueName
+                $queueName,
+                $this->delay
             );
         }