1. class
  2. Lemonade
  3. \
  4. Framework
  5. \
  6. Queue
  7. \
  8. Transport
  9. \
  10. DatabaseQueueTransport

DatabaseQueueTransport

final class DatabaseQueueTransport implements QueueTransportInterface (View source)

Methods

__construct(DatabaseDriverInterface $db, MessageSerializer $serializer, string $table = 'system_queue_job', string $failedTable = 'system_queue_failed_job')
void
enqueue(QueuedMessage $message, int $delaySeconds = 0)
void
QueuedMessage|null
dequeue(string $queue)
QueuedMessage|null
void
ack(QueuedMessage $message)
void
void
fail(QueuedMessage $message, string $error)
void

Details

__construct

__construct(DatabaseDriverInterface $db, MessageSerializer $serializer, string $table = 'system_queue_job', string $failedTable = 'system_queue_failed_job')
at line 15

No description

Parameters

DatabaseDriverInterface $db
MessageSerializer $serializer
string $table
string $failedTable

enqueue

void enqueue(QueuedMessage $message, int $delaySeconds = 0)
at line 22

No description

Parameters

QueuedMessage $message
int $delaySeconds

Return Value

void

dequeue

QueuedMessage|null dequeue(string $queue)
at line 37

No description

Parameters

string $queue

Return Value

QueuedMessage|null

ack

void ack(QueuedMessage $message)
at line 90

No description

Parameters

QueuedMessage $message

Return Value

void

fail

void fail(QueuedMessage $message, string $error)
at line 103

No description

Parameters

QueuedMessage $message
string $error

Return Value

void