Class SimpleDatabaseQueue
A simple single threaded queue storing the messages in a small database table.
- Avisota\Queue\SimpleDatabaseQueue implements Avisota\Queue\MutableQueueInterface, Avisota\Queue\EventEmittingQueueInterface, Avisota\Queue\LoggingQueueInterface
Namespace: Avisota\Queue
Package: Avisota\Queue
Located at src/Avisota/Queue/SimpleDatabaseQueue.php
Package: Avisota\Queue
Located at src/Avisota/Queue/SimpleDatabaseQueue.php
public static
|
|
public
|
#
__construct( Doctrine\DBAL\Connection $connection, Doctrine\DBAL\Connection $tableName, string $createTableIfNotExists = false, Psr\Log\LoggerInterface $logger = null, Symfony\Component\EventDispatcher\EventDispatcher $eventDispatcher = null )
|
public
|
#
setEventDispatcher( Symfony\Component\EventDispatcher\EventDispatcher $eventDispatcher = null )
Set the event dispatcher for this queue. |
public
Symfony\Component\EventDispatcher\EventDispatcher|null
|
|
public
|
|
public
Psr\Log\LoggerInterface|null
|
|
public
boolean
|
|
public
integer
|
|
public
|
|
public
|
#
execute(
Execute a queue and send all messages. |
protected
array[]
|
|
protected
|
|
protected
|
#
transport(
Do the transport of the message and create a status information object. |
protected
|
|
protected
|
#
logPreTransportStatus(
|
protected
|
#
logSuccessfulStatus(
|
protected
|
#
logFailedStatus(
|
public
boolean
|
#
enqueue(
Enqueue a message. |
public
boolean
|
protected
Doctrine\DBAL\Connection
|
$connection |
|
|
protected
string
|
$tableName |
|
|
protected
Psr\Log\LoggerInterface
|
$logger |
|
|
protected
Symfony\Component\EventDispatcher\EventDispatcher
|
$eventDispatcher |
|