class
Illuminate
/
Queue
/
Listener
Listener
Properties
protected
$commandPath string
The command working path.
Default: null
protected
$environment string
The environment the workers should run under.
Default: null
protected
$sleep int
The amount of seconds to wait before polling the queue.
Default: 3
protected
$maxTries int
The number of times to try a job before logging it failed.
Methods
public
__construct ( $commandPath ) : void
Create a new queue listener.
Parameters
- $commandPath string
protected
phpBinary ( ) : string
Get the PHP binary.
protected
artisanBinary ( ) : string
Get the Artisan binary.
public
listen ( $connection , $queue , ListenerOptions $options ) : void
Listen to the given queue connection.
Parameters
- $connection string
- $queue string
- $options ListenerOptions
public
makeProcess ( $connection , $queue , ListenerOptions $options ) : Symfony\...\Process
Create a new Symfony process for the worker.
Parameters
- $connection string
- $queue string
- $options ListenerOptions
protected
addEnvironment ( $command , ListenerOptions $options ) : array
Add the environment option to the given command.
Parameters
- $command array
- $options ListenerOptions
protected
createCommand ( $connection , $queue , ListenerOptions $options ) : array
Create the command with the listener options.
Parameters
- $connection string
- $queue string
- $options ListenerOptions
public
runProcess ( Symfony\...\Process $process , $memory ) : void
Run the given process.
Parameters
- $process Symfony\...\Process
- $memory int
protected
handleWorkerOutput ( $type , $line ) : void
Handle output from the worker process.
Parameters
- $type int
- $line string
public
memoryExceeded ( $memoryLimit ) : bool
Determine if the memory limit has been exceeded.
Parameters
- $memoryLimit int
public
stop ( ) : void
Stop listening and bail out of the script.