1. classe
  2. Bow
  3. \
  4. Queue
  5. \
  6. Adapters
  7. \
  8. QueueAdapter

QueueAdapter

abstract classe QueueAdapter (Voir la source)

Méthodes

string
serializeProducer(ProducerService $producer)

Create producer serialization

configure(array $config)

Make adapter configuration

setWatch(string $queue)

Watch the the queue name

setRetry(int $retry)

Set the retry value

push(ProducerService $producer)

Push new producer

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.

run(string $queue = null)

Start the worker server

Détails

à la ligne 15
string serializeProducer(ProducerService $producer)

Create producer serialization

Paramètres

ProducerService $producer

Valeur de retour

string

à la ligne 25
abstract configure(array $config)

Make adapter configuration

Paramètres

array $config

à la ligne 32
abstract setWatch(string $queue)

Watch the the queue name

Paramètres

string $queue

à la ligne 39
abstract setRetry(int $retry)

Set the retry value

Paramètres

int $retry

à la ligne 46
abstract push(ProducerService $producer)

Push new producer

Paramètres

ProducerService $producer

à la ligne 53
abstract size(string $queue)

Get the queue size

Paramètres

string $queue

à la ligne 62
abstract void deleteJob(string $queue, string|int $id)

Delete a message from the queue.

Paramètres

string $queue
string|int $id

Valeur de retour

void

à la ligne 70
abstract string getQueue(string $queue = null)

Get the queue or return the default.

Paramètres

string $queue

Valeur de retour

string

à la ligne 77
abstract run(string $queue = null)

Start the worker server

Paramètres

string $queue