DatabaseQueueAdapter
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}
int
getQueueId(string $name)
Get the identifier of a queue given its name.
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}
Details
__construct($options = [], Queue $queue = null)
{@inheritdoc}
isExists($name)
{@inheritdoc}
protected int
getQueueId(string $name)
Get the identifier of a queue given its name.
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}