File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -147,7 +147,7 @@ public static function dequeue($queue, $items = Array())
147
147
* Remove specified queue
148
148
*
149
149
* @param string $queue The name of the queue to remove.
150
- * @return integer number of deleted items
150
+ * @return integer Number of deleted items
151
151
*/
152
152
public static function removeQueue ($ queue )
153
153
{
@@ -277,12 +277,12 @@ private static function removeItems($queue, $items = Array())
277
277
$ originalQueue = 'queue: ' . $ queue ;
278
278
$ tempQueue = $ originalQueue . ':temp: ' . time ();
279
279
$ requeueQueue = $ tempQueue . ':requeue ' ;
280
-
280
+
281
281
// move each item from original queue to temp queue and process it
282
282
$ finished = false ;
283
283
while (!$ finished ) {
284
284
$ string = self ::redis ()->rpoplpush ($ originalQueue , self ::redis ()->getPrefix () . $ tempQueue );
285
-
285
+
286
286
if (!empty ($ string )) {
287
287
if (self ::matchItem ($ string , $ items )) {
288
288
self ::redis ()->rpop ($ tempQueue );
@@ -307,7 +307,7 @@ private static function removeItems($queue, $items = Array())
307
307
// remove temp queue and requeue queue
308
308
self ::redis ()->del ($ requeueQueue );
309
309
self ::redis ()->del ($ tempQueue );
310
-
310
+
311
311
return $ counter ;
312
312
}
313
313
You can’t perform that action at this time.
0 commit comments