\think\queue\connectorTopthink

Summary

Methods

Properties

Constants

push()
later()
pop()
marshal()
__construct()
release()
pushRaw()
deleteMessage()
__destruct()

No public properties found

No constants found

createPayload()
createPlainPayload()
setMeta()
apiCall()
callWithRetries()
jsonDecode()
waitRandomInterval()
reportHttpError()
marshalPushedJob()

$options
$request
$url
$curl
$last_status
$headers

N/A

No private methods found

No private properties found

N/A

File: vendor/topthink/think-queue/src/queue/connector/Topthink.php
Package: Default
Class hierarchy: \think\queue\Connector

\think\queue\connector\Topthink

Properties

$options

$options :

Type

$request

$request : \think\facade\Request

Type

\think\facade\Request

$url

$url :

Type

$curl

$curl :

Type

$last_status

$last_status :

Type

$headers

$headers :

Type

Methods

push()

push(  $job,   $data = '',   $queue = null)

Parameters

	$job
	$data
	$queue

later()

later(  $delay,   $job,   $data = '',   $queue = null)

Parameters

	$delay
	$job
	$data
	$queue

pop()

pop(  $queue = null)

Parameters

$queue

marshal()

marshal()

__construct()

__construct(array  $options)

Parameters

array

$options

release()

release(  $queue,   $job,   $delay)

Parameters

	$queue
	$job
	$delay

pushRaw()

pushRaw(  $delay,   $queue,   $payload,   $attempts)

Parameters

	$delay
	$queue
	$payload
	$attempts

deleteMessage()

deleteMessage(  $queue,   $id)

Parameters

	$queue
	$id

__destruct()

__destruct()

createPayload()

createPayload(  $job,   $data = '',   $queue = null)

Parameters

	$job
	$data
	$queue

createPlainPayload()

createPlainPayload(  $job,   $data)

Parameters

	$job
	$data

setMeta()

setMeta(  $payload,   $key,   $value)

Parameters

	$payload
	$key
	$value

apiCall()

apiCall(  $type,   $url,   $params = array())

Parameters

	$type
	$url
	$params

callWithRetries()

callWithRetries()

jsonDecode()

jsonDecode(  $response)

Parameters

$response

waitRandomInterval()

waitRandomInterval(  $retry)

Parameters

$retry

reportHttpError()

reportHttpError(  $status,   $text)

Parameters

	$status
	$text

marshalPushedJob()

marshalPushedJob() : object

Marshal out the pushed job and payload.

Returns

object