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

QueueAdapter

abstract class QueueAdapter (View source)

Methods

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

Details

at line 15
string serializeProducer(ProducerService $producer)

Create producer serialization

Parameters

ProducerService $producer

Return Value

string

at line 25
abstract configure(array $config)

Make adapter configuration

Parameters

array $config

at line 32
abstract setWatch(string $queue)

Watch the the queue name

Parameters

string $queue

at line 39
abstract setRetry(int $retry)

Set the retry value

Parameters

int $retry

at line 46
abstract push(ProducerService $producer)

Push new producer

Parameters

ProducerService $producer

at line 53
abstract size(string $queue)

Get the queue size

Parameters

string $queue

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

Delete a message from the queue.

Parameters

string $queue
string|int $id

Return Value

void

at line 70
abstract string getQueue(string $queue = null)

Get the queue or return the default.

Parameters

string $queue

Return Value

string

at line 77
abstract run(string $queue = null)

Start the worker server

Parameters

string $queue