<form method="POST">
    <h3>Editing: ListenCommand.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php

namespace Illuminate\Queue\Console;

use Illuminate\Console\Command;
use Illuminate\Queue\Listener;
use Illuminate\Queue\ListenerOptions;

class ListenCommand extends Command
{
    /**
     * The console command name.
     *
     * @var string
     */
    protected $signature = 'queue:listen
                            {connection? : The name of connection}
                            {--name=default : The name of the worker}
                            {--delay=0 : The number of seconds to delay failed jobs (Deprecated)}
                            {--backoff=0 : The number of seconds to wait before retrying a job that encountered an uncaught exception}
                            {--force : Force the worker to run even in maintenance mode}
                            {--memory=128 : The memory limit in megabytes}
                            {--queue= : The queue to listen on}
                            {--sleep=3 : Number of seconds to sleep when no job is available}
                            {--timeout=60 : The number of seconds a child process can run}
                            {--tries=1 : Number of times to attempt a job before logging it failed}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Listen to a given queue';

    /**
     * The queue listener instance.
     *
     * @var \Illuminate\Queue\Listener
     */
    protected $listener;

    /**
     * Create a new queue listen command.
     *
     * @param  \Illuminate\Queue\Listener  $listener
     * @return void
     */
    public function __construct(Listener $listener)
    {
        parent::__construct();

        $this-&gt;setOutputHandler($this-&gt;listener = $listener);
    }

    /**
     * Execute the console command.
     *
     * @return void
     */
    public function handle()
    {
        // We need to get the right queue for the connection which is set in the queue
        // configuration file for the application. We will pull it based on the set
        // connection being run for the queue operation currently being executed.
        $queue = $this-&gt;getQueue(
            $connection = $this-&gt;input-&gt;getArgument('connection')
        );

        $this-&gt;listener-&gt;listen(
            $connection, $queue, $this-&gt;gatherOptions()
        );
    }

    /**
     * Get the name of the queue connection to listen on.
     *
     * @param  string  $connection
     * @return string
     */
    protected function getQueue($connection)
    {
        $connection = $connection ?: $this-&gt;laravel['config']['queue.default'];

        return $this-&gt;input-&gt;getOption('queue') ?: $this-&gt;laravel['config']-&gt;get(
            &quot;queue.connections.{$connection}.queue&quot;, 'default'
        );
    }

    /**
     * Get the listener options for the command.
     *
     * @return \Illuminate\Queue\ListenerOptions
     */
    protected function gatherOptions()
    {
        $backoff = $this-&gt;hasOption('backoff')
                ? $this-&gt;option('backoff')
                : $this-&gt;option('delay');

        return new ListenerOptions(
            $this-&gt;option('name'),
            $this-&gt;option('env'),
            $backoff,
            $this-&gt;option('memory'),
            $this-&gt;option('timeout'),
            $this-&gt;option('sleep'),
            $this-&gt;option('tries'),
            $this-&gt;option('force')
        );
    }

    /**
     * Set the options on the queue listener.
     *
     * @param  \Illuminate\Queue\Listener  $listener
     * @return void
     */
    protected function setOutputHandler(Listener $listener)
    {
        $listener-&gt;setOutputHandler(function ($type, $line) {
            $this-&gt;output-&gt;write($line);
        });
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>