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

ProducerService
unserializeProducer(string $producer)

Create producer unserialize

QueueAdapter
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

Détails

à la ligne 18
string serializeProducer(ProducerService $producer)

Create producer serialization

Paramètres

ProducerService $producer

Valeur de retour

string

à la ligne 29
ProducerService unserializeProducer(string $producer)

Create producer unserialize

Paramètres

string $producer

Valeur de retour

ProducerService

à la ligne 40
abstract QueueAdapter configure(array $config)

Make adapter configuration

Paramètres

array $config

Valeur de retour

QueueAdapter

à la ligne 47
abstract void setWatch(string $queue)

Watch the the queue name

Paramètres

string $queue

Valeur de retour

void

à la ligne 54
abstract void setRetry(int $retry)

Set the retry value

Paramètres

int $retry

Valeur de retour

void

à la ligne 61
abstract void push(ProducerService $producer)

Push new producer

Paramètres

ProducerService $producer

Valeur de retour

void

à la ligne 69
abstract int size(string $queue)

Get the queue size

Paramètres

string $queue

Valeur de retour

int

à la ligne 78
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 86
abstract string getQueue(string $queue = null)

Get the queue or return the default.

Paramètres

string $queue

Valeur de retour

string

à la ligne 93
abstract void run(string|null $queue = null)

Start the worker server

Paramètres

string|null $queue

Valeur de retour

void