class DatabaseQueueAdapter extends AbstractAdapter (View source)

Properties

protected Connection $db The connection to the current database.

Methods

__construct($options = [], Queue $queue = null)

{@inheritdoc}

isExists($name)

{@inheritdoc}

create($name, $timeout = null)

{@inheritdoc}

delete($name)

{@inheritdoc}

getQueues()

{@inheritdoc}

count(Queue $queue = null)

{@inheritdoc}

send($message, Queue $queue = null)

{@inheritdoc}

receive($maxMessages = null, $timeout = null, Queue $queue = null)

{@inheritdoc}

deleteMessage(Message $message)

{@inheritdoc}

getCapabilities()

{@inheritdoc}

int
getQueueId(string $name)

Get the identifier of a queue given its name.

Details

__construct($options = [], Queue $queue = null)

{@inheritdoc}

Parameters

$options
Queue $queue

See also

\ZendQueue\Adapter::__construct()

isExists($name)

{@inheritdoc}

Parameters

$name

See also

\ZendQueue\Adapter::isExists()

create($name, $timeout = null)

{@inheritdoc}

Parameters

$name
$timeout

See also

\ZendQueue\Adapter::create()

delete($name)

{@inheritdoc}

Parameters

$name

See also

\ZendQueue\Adapter::delete()

getQueues()

{@inheritdoc}

See also

\ZendQueue\Adapter::getQueues()

count(Queue $queue = null)

{@inheritdoc}

Parameters

Queue $queue

See also

\ZendQueue\Adapter::count()

send($message, Queue $queue = null)

{@inheritdoc}

Parameters

$message
Queue $queue

See also

\ZendQueue\Adapter::send()

receive($maxMessages = null, $timeout = null, Queue $queue = null)

{@inheritdoc}

Parameters

$maxMessages
$timeout
Queue $queue

See also

\ZendQueue\Adapter::receive()

deleteMessage(Message $message)

{@inheritdoc}

Parameters

Message $message

See also

\ZendQueue\Adapter::deleteMessage()

getCapabilities()

{@inheritdoc}

See also

\ZendQueue\Adapter::getCapabilities()

protected int getQueueId(string $name)

Get the identifier of a queue given its name.

Parameters

string $name The name of a queue

Return Value

int

Exceptions

RuntimeException Throws a RuntimeException if the queue does not exist