批处理进程调整

src/Handler/RedisQueueBatchHandler.php

@@ -95,6 +95,7 @@ abstract class RedisQueueBatchHandler
                     }
 
                 }else{
+                    $this->redis->lTrim($this->queue_name,count($arr),-1);
                     $this->retry = 0;
                     $this->errorWriteToFile($formatArr,$exception);
                 }