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

BeanstalkdAdapter

class BeanstalkdAdapter extends QueueAdapter (View source)

Methods

string
serializeProducer(ProducerService $producer)

Create producer serialization

from  QueueAdapter
configure(array $queue)

Configure Beanstalkd driver

setWatch(string $name)

Get connexion

setRetry(int $retry)

Get connexion

push(ProducerService $producer)

Queue a job

size(string $queue = null)

Get the size of the queue.

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

Delete a message from the Beanstalk queue.

string
getQueue(string $queue = null)

Get the queue or return the default.

run(string $queue = null)

Run the worker

Details

in QueueAdapter at line 15
string serializeProducer(ProducerService $producer)

Create producer serialization

Parameters

ProducerService $producer

Return Value

string

at line 32
configure(array $queue)

Configure Beanstalkd driver

Parameters

array $queue

at line 46
setWatch(string $name)

Get connexion

Parameters

string $name

at line 57
setRetry(int $retry)

Get connexion

Parameters

int $retry

at line 106
push(ProducerService $producer)

Queue a job

Parameters

ProducerService $producer

at line 93
size(string $queue = null)

Get the size of the queue.

Parameters

string $queue

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

Delete a message from the Beanstalk queue.

Parameters

string $queue
string|int $id

Return Value

void

at line 82
string getQueue(string $queue = null)

Get the queue or return the default.

Parameters

string $queue

Return Value

string

at line 119
run(string $queue = null)

Run the worker

Parameters

string $queue