Add support for pushing anonymous functions onto the queue. Proceed with extreme, as in wait for me to screencast this.

Author: taylorotwell

composer.json

@@ -69,6 +69,9 @@
         "phpunit/phpunit": "3.7.*"
     },
     "autoload": {
+        "classmap": [
+            ["src/Illuminate/Queue/IlluminateQueueClosure.php"]
+        ],
     	"files": [
             "src/Illuminate/Support/helpers.php"
     	],

src/Illuminate/Queue/IlluminateQueueClosure.php

@@ -0,0 +1,19 @@
+<?php
+
+class IlluminateQueueClosure {
+
+	/**
+	 * Fire the Closure based queue job.
+	 *
+	 * @param  \Illuminate\Queue\Jobs\Job  $job
+	 * @param  array  $data
+	 * @return void
+	 */
+	public function fire($job, $data)
+	{
+		$closure = unserialize($data['closure']);
+
+		$closure($job);
+	}
+
+}

src/Illuminate/Queue/Jobs/SyncJob.php

@@ -1,5 +1,6 @@
 <?php namespace Illuminate\Queue\Jobs;
 
+use Closure;
 use Illuminate\Container\Container;
 
 class SyncJob extends Job {
@@ -40,7 +41,14 @@ public function __construct(Container $container, $job, $data = '')
 	 */
 	public function fire()
 	{
-		$this->resolveAndFire(array('job' => $this->job, 'data' => $this->data));
+		if ($this->job instanceof Closure)
+		{
+			call_user_func($this->job, $this, $this->data);
+		}
+		else
+		{
+			$this->resolveAndFire(array('job' => $this->job, 'data' => $this->data));
+		}
 	}
 
 	/**

src/Illuminate/Queue/Queue.php

@@ -1,6 +1,8 @@
 <?php namespace Illuminate\Queue;
 
+use Closure;
 use Illuminate\Container\Container;
+use Illuminate\Support\SerializableClosure;
 
 abstract class Queue {
 
@@ -30,7 +32,28 @@ public function marshal()
 	 */
 	protected function createPayload($job, $data = '')
 	{
-		return json_encode(array('job' => $job, 'data' => $data));
+		if ($job instanceof Closure)
+		{
+			return json_encode($this->createClosurePayload($job, $data));
+		}
+		else
+		{
+			return json_encode(array('job' => $job, 'data' => $data));
+		}
+	}
+
+	/**
+	 * Create a payload string for the given Closure job.
+	 *
+	 * @param  \Closure  $job
+	 * @param  mixed  $data
+	 * @return string
+	 */
+	protected function createClosurePayload($job, $data)
+	{
+		$closure = serialize(new SerializableClosure($job));
+
+		return array('job' => 'IlluminateQueueClosure', 'data' => compact('closure'));
 	}
 
 	/**

src/Illuminate/Queue/composer.json

@@ -24,7 +24,7 @@
             "Illuminate\\Queue": ""
         },
         "classmap": [
-            "Illuminate/Queue/Pheanstalk"
+            "IlluminateQueueClosure.php"
         ]
     },
     "target-dir": "Illuminate/Queue",

src/Illuminate/Support/SerializableClosure.php

@@ -175,6 +175,16 @@ public function unserialize($serialized)
 		$this->reflection = new ReflectionFunction($this->closure);
 	}
 
+	/**
+	 * Get the unserialized Closure instance.
+	 *
+	 * @return \Closure
+	 */
+	public function getClosure()
+	{
+		return $this->closure;
+	}
+
 	/**
 	 * Invoke the contained Closure.
 	 *

tests/Queue/QueueIronQueueTest.php

@@ -18,6 +18,16 @@ public function testPushProperlyPushesJobOntoIron()
 	}
 
 
+	public function testPushProperlyPushesJobOntoIronWithClosures()
+	{
+		$queue = new Illuminate\Queue\IronQueue($iron = m::mock('IronMQ'), m::mock('Illuminate\Http\Request'), 'default');
+		$name = 'Foo';
+		$closure = new Illuminate\Support\SerializableClosure($innerClosure = function() use ($name) { return $name; });
+		$iron->shouldReceive('postMessage')->once()->with('default', json_encode(array('job' => 'IlluminateQueueClosure', 'data' => array('closure' => serialize($closure)))));
+		$queue->push($innerClosure);
+	}
+
+
 	public function testDelayedPushProperlyPushesJobOntoIron()
 	{
 		$queue = new Illuminate\Queue\IronQueue($iron = m::mock('IronMQ'), m::mock('Illuminate\Http\Request'), 'default');

tests/Queue/QueueSyncJobTest.php

@@ -22,6 +22,16 @@ public function testFireResolvesAndFiresJobClass()
 	}
 
 
+	public function testClosuresCanBeFiredBySyncJob()
+	{
+		unset($_SERVER['__queue.closure']);
+		$job = new Illuminate\Queue\Jobs\SyncJob(new Illuminate\Container\Container, function() { $_SERVER['__queue.closure'] = true; }, 'data');
+		$job->fire();
+
+		$this->assertTrue($_SERVER['__queue.closure']);
+	}
+
+
 	public function testFireResolvesAndFiresJobClassWithCorrectMethod()
 	{
 		$container = m::mock('Illuminate\Container\Container');