final class SyncQueueTransport implements QueueTransportInterface (View source)

Methods

void
enqueue(QueuedMessage $message, int $delaySeconds = 0)
void
dequeue(string $queue)
void
ack(QueuedMessage $message)
void
void
fail(QueuedMessage $message, string $error)
void

Details

enqueue

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

No description

Parameters

QueuedMessage $message
int $delaySeconds

Return Value

void

dequeue

QueuedMessage|null dequeue(string $queue)

No description

Parameters

string $queue

Return Value

QueuedMessage|null

ack

void ack(QueuedMessage $message)

No description

Parameters

QueuedMessage $message

Return Value

void

fail

void fail(QueuedMessage $message, string $error)

No description

Parameters

QueuedMessage $message
string $error

Return Value

void