Merge pull request #1 from php-enqueue/queue-later

Add Queue::later support.

Author: makasim

Queue.php

@@ -50,20 +50,6 @@ public function push($job, $data = '', $queue = null)
         return $this->pushRaw($this->createPayload($job, $data), $queue);
     }
 
-    /**
-     * Push a new job onto the queue.
-     *
-     * @param string $queue
-     * @param string $job
-     * @param mixed  $data
-     *
-     * @return mixed
-     */
-    public function pushOn($queue, $job, $data = '')
-    {
-        new \LogicException('to be implemented');
-    }
-
     /**
      * {@inheritdoc}
      */
@@ -80,7 +66,13 @@ public function pushRaw($payload, $queue = null, array $options = [])
      */
     public function later($delay, $job, $data = '', $queue = null)
     {
-        new \LogicException('to be implemented');
+        $message = $this->psrContext->createMessage($this->createPayload($job, $data));
+
+        return $this->psrContext->createProducer()
+            ->setDeliveryDelay($this->secondsUntil($delay) * 1000)
+
+            ->send($this->getQueue($queue), $message)
+        ;
     }
 
     /**

composer.json

@@ -13,13 +13,13 @@
     "require": {
         "php": ">=5.6",
         "illuminate/queue": "^5.4",
-        "queue-interop/queue-interop": "^0.5"
+        "queue-interop/queue-interop": "^0.6@dev"
     },
     "require-dev": {
         "phpunit/phpunit": "~5.5",
-        "enqueue/enqueue": "^0.6@dev",
-        "enqueue/null": "^0.6@dev",
-        "enqueue/test": "^0.6@dev"
+        "enqueue/enqueue": "^0.7@dev",
+        "enqueue/null": "^0.7@dev",
+        "enqueue/test": "^0.7@dev"
     },
     "autoload": {
         "psr-4": { "Enqueue\\LaravelQueue\\": "" },