Class yii\queue\redis\Queue

All Classes | Properties | Methods | Events | Constants

Inheritance	yii\queue\redis\Queue » yii\queue\cli\Queue » yii\queue\Queue » yii\base\Component
Implements	yii\base\BootstrapInterface

Redis Queue

Public Properties

Hide inherited properties

Property	Type	Description	Defined By
$attempts	integer	Default attempt count	yii\queue\Queue
$channel	string		yii\queue\redis\Queue
$commandClass	string	Command class name	yii\queue\redis\Queue
$commandOptions	array	Of additional options of command	yii\queue\cli\Queue
$loopConfig	array\|string		yii\queue\cli\Queue
$messageHandler	callable\|null		yii\queue\cli\Queue
$redis	\yii\redis\Connection\|array\|string		yii\queue\redis\Queue
$serializer	yii\queue\serializers\SerializerInterface\|array		yii\queue\Queue
$strictJobType	boolean	Whether to enable strict job type control.	yii\queue\Queue
$ttr	integer	Default time to reserve a job	yii\queue\Queue

Public Methods

Hide inherited methods

Method	Description	Defined By
bootstrap()		yii\queue\cli\Queue
clear()	Clears the queue	yii\queue\redis\Queue
delay()	Sets delay for later execute	yii\queue\Queue
execute()		yii\queue\cli\Queue
getWorkerPid()	Gets process ID of a worker.	yii\queue\cli\Queue
handleError()		yii\queue\Queue
init()		yii\queue\redis\Queue
isDone()		yii\queue\Queue
isReserved()		yii\queue\Queue
isWaiting()		yii\queue\Queue
priority()	Sets job priority	yii\queue\Queue
push()	Pushes job into queue	yii\queue\Queue
remove()	Removes a job by ID	yii\queue\redis\Queue
run()	Listens queue and runs each job.	yii\queue\redis\Queue
status()		yii\queue\redis\Queue
ttr()	Sets TTR for job execute	yii\queue\Queue

Protected Methods

Hide inherited methods

Method	Description	Defined By
closeWorker()		yii\queue\redis\Queue
delete()	Deletes message by ID	yii\queue\redis\Queue
getCommandId()		yii\queue\cli\Queue
handleMessage()		yii\queue\cli\Queue
moveExpired()		yii\queue\redis\Queue
openWorker()		yii\queue\redis\Queue
pushMessage()		yii\queue\redis\Queue
reserve()		yii\queue\redis\Queue
runWorker()	Runs worker.	yii\queue\cli\Queue

Events

Hide inherited events

Event	Type	Description	Defined By
EVENT_AFTER_ERROR	yii\queue\ExecEvent		yii\queue\Queue
EVENT_AFTER_EXEC	yii\queue\ExecEvent		yii\queue\Queue
EVENT_AFTER_PUSH	yii\queue\PushEvent		yii\queue\Queue
EVENT_BEFORE_EXEC	yii\queue\ExecEvent		yii\queue\Queue
EVENT_BEFORE_PUSH	yii\queue\PushEvent		yii\queue\Queue
EVENT_WORKER_START	yii\queue\cli\WorkerEvent	(available since version 2.0.2)	yii\queue\cli\Queue
EVENT_WORKER_STOP	yii\queue\cli\WorkerEvent	(available since version 2.0.2)	yii\queue\cli\Queue

Constants

Hide inherited constants

Constant	Value	Defined By
STATUS_DONE	3	yii\queue\Queue
STATUS_RESERVED	2	yii\queue\Queue
STATUS_WAITING	1	yii\queue\Queue

Property Details

$channel public property

public string $channel = 'queue'

$commandClass public property

Command class name

public string $commandClass = \yii\queue\redis\Command::class

$redis public property

public \yii\redis\Connection|array|string $redis = 'redis'

Method Details

clear() public method (available since version 2.0.1)

Clears the queue

public void clear ( )

closeWorker() protected method

protected void closeWorker ( )

delete() protected method

Deletes message by ID

protected void delete ( $id )
$id	integer	Of a message

init() public method

public void init ( )

moveExpired() protected method

protected void moveExpired ( $from )
$from	string

openWorker() protected method

protected void openWorker ( )

pushMessage() protected method

protected string pushMessage ( $message, $ttr, $delay, $priority )
$message	string
$ttr	integer	Time to reserve in seconds
$delay	integer
$priority	mixed
return	string	Id of a job message

remove() public method (available since version 2.0.1)

Removes a job by ID

public boolean remove ( $id )
$id	integer	Of a job

reserve() protected method

protected array\|null reserve ( $timeout )
$timeout	integer	Timeout
return	array\|null	Payload

run() public method (available since version 2.0.2)

Listens queue and runs each job.

public null\|integer run ( $repeat, $timeout = 0 )
$repeat	boolean	Whether to continue listening when queue is empty.
$timeout	integer	Number of seconds to wait for next message.
return	null\|integer	Exit code.

status() public method

public integer status ( $id )
$id	string	Of a job message
return	integer	Status code