abstract class QueueAdapter (View source)

Methods

string
serializeProducer(ProducerService $producer)

Create producer serialization

unserializeProducer(string $producer)

Create producer unserialize

configure(array $config)

Make adapter configuration

void
setWatch(string $queue)

Watch the the queue name

void
setRetry(int $retry)

Set the retry value

void
push(ProducerService $producer)

Push new producer

int
size(string $queue)

Get the queue size

void
deleteJob(string $queue, string|int $id)

Delete a message from the queue.

string
getQueue(string $queue = null)

Get the queue or return the default.

void
run(string|null $queue = null)

Start the worker server

Details

string serializeProducer(ProducerService $producer)

Create producer serialization

Parameters

ProducerService $producer

Return Value

string

ProducerService unserializeProducer(string $producer)

Create producer unserialize

Parameters

string $producer

Return Value

ProducerService

abstract QueueAdapter configure(array $config)

Make adapter configuration

Parameters

array $config

Return Value

QueueAdapter

abstract void setWatch(string $queue)

Watch the the queue name

Parameters

string $queue

Return Value

void

abstract void setRetry(int $retry)

Set the retry value

Parameters

int $retry

Return Value

void

abstract void push(ProducerService $producer)

Push new producer

Parameters

ProducerService $producer

Return Value

void

abstract int size(string $queue)

Get the queue size

Parameters

string $queue

Return Value

int

abstract void deleteJob(string $queue, string|int $id)

Delete a message from the queue.

Parameters

string $queue
string|int $id

Return Value

void

abstract string getQueue(string $queue = null)

Get the queue or return the default.

Parameters

string $queue

Return Value

string

abstract void run(string|null $queue = null)

Start the worker server

Parameters

string|null $queue

Return Value

void