Added a way to get the size of the queue (laravel#14662)

src/Illuminate/Contracts/Queue/Queue.php

@@ -63,4 +63,12 @@ public function laterOn($queue, $delay, $job, $data = '');
      * @return \Illuminate\Contracts\Queue\Job|null
      */
     public function pop($queue = null);
+
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function size($queue = null);
 }

src/Illuminate/Queue/BeanstalkdQueue.php

@@ -108,6 +108,19 @@ public function pop($queue = null)
         }
     }
 
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function size($queue = null)
+    {
+        $queue = $this->getQueue($queue);
+
+        return (int) $this->pheanstalk->statsTube($queue)->total_jobs;
+    }
+
     /**
      * Delete a message from the Beanstalk queue.
      *

src/Illuminate/Queue/DatabaseQueue.php

@@ -174,6 +174,19 @@ public function pop($queue = null)
         $this->database->commit();
     }
 
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function size($queue = null)
+    {
+        return $this->database->table($this->table)
+                    ->where('queue', $this->getQueue($queue))
+                    ->count();
+    }
+
     /**
      * Get the next available job for the queue.
      *

src/Illuminate/Queue/NullQueue.php

@@ -56,4 +56,15 @@ public function pop($queue = null)
     {
         //
     }
+
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function size($queue = null)
+    {
+        return 0;
+    }
 }

src/Illuminate/Queue/RedisQueue.php

@@ -131,6 +131,17 @@ public function pop($queue = null)
         }
     }
 
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function size($queue = null)
+    {
+        return (int) $this->getConnection()->llen($this->getQueue($queue));
+    }
+
     /**
      * Delete a reserved job from the queue.
      *

src/Illuminate/Queue/SqsQueue.php

@@ -116,6 +116,19 @@ public function pop($queue = null)
         }
     }
 
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function size($queue = null)
+    {
+        return (int) $this->sqs->getQueueAttributes([
+            'QueueUrl' => $this->getQueue($queue),
+        ])->get('ApproximateNumberOfMessages');
+    }
+
     /**
      * Get the queue or return the default.
      *

src/Illuminate/Queue/SyncQueue.php

@@ -94,6 +94,17 @@ public function pop($queue = null)
         //
     }
 
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string  $queue
+     * @return int
+     */
+    public function size($queue = null)
+    {
+        return 0;
+    }
+
     /**
      * Resolve a Sync job instance.
      *