formatting

Author: taylorotwell

src/Illuminate/Contracts/Queue/ClearableQueue.php

@@ -5,7 +5,7 @@
 interface ClearableQueue
 {
     /**
-     * Clear all jobs from the queue.
+     * Delete all of the jobs from the queue.
      *
      * @param  string  $queue
      * @return int

src/Illuminate/Queue/Console/ClearCommand.php

@@ -25,7 +25,7 @@ class ClearCommand extends Command
      *
      * @var string
      */
-    protected $description = 'Clear the queue';
+    protected $description = 'Delete all of the jobs from the specified queue';
 
     /**
      * Execute the console command.
@@ -45,14 +45,15 @@ public function handle()
         // configuration file for the application. We will pull it based on the set
         // connection being run for the queue operation currently being executed.
         $queueName = $this->getQueue($connection);
+
         $queue = ($this->laravel['queue'])->connection($connection);
 
         if ($queue instanceof ClearableQueue) {
             $count = $queue->clear($queueName);
 
-            $this->line('<info>Cleared '.$count.' jobs from the '.$queueName.' queue</info> ');
+            $this->line('<info>Cleared '.$count.' jobs from the ['.$queueName.'] queue</info> ');
         } else {
-            $this->line('<error>Clearing queues is not supported on '.(new ReflectionClass($queue))->getShortName().'</error> ');
+            $this->line('<error>Clearing queues is not supported on ['.(new ReflectionClass($queue))->getShortName().']</error> ');
         }
 
         return 0;

src/Illuminate/Queue/DatabaseQueue.php

@@ -304,19 +304,6 @@ protected function markJobAsReserved($job)
         return $job;
     }
 
-    /**
-     * Clear all jobs from the queue.
-     *
-     * @param  string  $queue
-     * @return int
-     */
-    public function clear($queue)
-    {
-        return $this->database->table($this->table)
-                    ->where('queue', $this->getQueue($queue))
-                    ->delete();
-    }
-
     /**
      * Delete a reserved job from the queue.
      *
@@ -354,6 +341,19 @@ public function deleteAndRelease($queue, $job, $delay)
         });
     }
 
+    /**
+     * Delete all of the jobs from the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function clear($queue)
+    {
+        return $this->database->table($this->table)
+                    ->where('queue', $this->getQueue($queue))
+                    ->delete();
+    }
+
     /**
      * Get the queue or return the default.
      *

src/Illuminate/Queue/LuaScripts.php

@@ -20,24 +20,6 @@ public static function size()
 LUA;
     }
 
-    /**
-     * Get the Lua script for clearing the queue.
-     *
-     * KEYS[1] - The name of the primary queue
-     * KEYS[2] - The name of the "delayed" queue
-     * KEYS[3] - The name of the "reserved" queue
-     *
-     * @return string
-     */
-    public static function clear()
-    {
-        return <<<'LUA'
-local size = redis.call('llen', KEYS[1]) + redis.call('zcard', KEYS[2]) + redis.call('zcard', KEYS[3])
-redis.call('del', KEYS[1], KEYS[2], KEYS[3])
-return size
-LUA;
-    }
-
     /**
      * Get the Lua script for pushing jobs onto the queue.
      *
@@ -142,6 +124,24 @@ public static function migrateExpiredJobs()
 end
 
 return val
+LUA;
+    }
+
+    /**
+     * Get the Lua script for removing all jobs from the queue.
+     *
+     * KEYS[1] - The name of the primary queue
+     * KEYS[2] - The name of the "delayed" queue
+     * KEYS[3] - The name of the "reserved" queue
+     *
+     * @return string
+     */
+    public static function clear()
+    {
+        return <<<'LUA'
+local size = redis.call('llen', KEYS[1]) + redis.call('zcard', KEYS[2]) + redis.call('zcard', KEYS[3])
+redis.call('del', KEYS[1], KEYS[2], KEYS[3])
+return size
 LUA;
     }
 }

src/Illuminate/Queue/RedisQueue.php

@@ -257,21 +257,6 @@ protected function retrieveNextJob($queue, $block = true)
         return [$job, $reserved];
     }
 
-    /**
-     * Clear all jobs from the queue.
-     *
-     * @param  string  $queue
-     * @return int
-     */
-    public function clear($queue)
-    {
-        $queue = $this->getQueue($queue);
-
-        return $this->getConnection()->eval(
-            LuaScripts::clear(), 3, $queue, $queue.':delayed', $queue.':reserved'
-        );
-    }
-
     /**
      * Delete a reserved job from the queue.
      *
@@ -302,6 +287,21 @@ public function deleteAndRelease($queue, $job, $delay)
         );
     }
 
+    /**
+     * Delete all of the jobs from the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function clear($queue)
+    {
+        $queue = $this->getQueue($queue);
+
+        return $this->getConnection()->eval(
+            LuaScripts::clear(), 3, $queue, $queue.':delayed', $queue.':reserved'
+        );
+    }
+
     /**
      * Get a random ID string.
      *