diff --git a/src/Connectors/RedisConnector.php b/src/Connectors/RedisConnector.php index f9ed449d..7dd42e79 100644 --- a/src/Connectors/RedisConnector.php +++ b/src/Connectors/RedisConnector.php @@ -19,7 +19,8 @@ public function connect(array $config) return new RedisQueue( $this->redis, $config['queue'], Arr::get($config, 'connection', $this->connection), - Arr::get($config, 'retry_after', 60) + Arr::get($config, 'retry_after', 60), + Arr::get($config, 'block_for', 0) ); } }