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
ProducerService
unserializeProducer(string $producer)

Create producer unserialize

from  QueueAdapter
QueueAdapter
configure(array $queue)

Configure Beanstalkd driver

void
setWatch(string $name)

Get connexion

void
setRetry(int $retry)

Get connexion

void
push(ProducerService $producer)

Queue a job

int
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.

void
run(string|null $queue = null)

Run the worker

Details

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

Create producer serialization

Parameters

ProducerService $producer

Return Value

string

in QueueAdapter at line 29
ProducerService unserializeProducer(string $producer)

Create producer unserialize

Parameters

string $producer

Return Value

ProducerService

at line 34
QueueAdapter configure(array $queue)

Configure Beanstalkd driver

Parameters

array $queue

Return Value

QueueAdapter

at line 47
void setWatch(string $name)

Get connexion

Parameters

string $name

Return Value

void

at line 58
void setRetry(int $retry)

Get connexion

Parameters

int $retry

Return Value

void

at line 107
void push(ProducerService $producer)

Queue a job

Parameters

ProducerService $producer

Return Value

void

at line 94
int size(string $queue = null)

Get the size of the queue.

Parameters

string $queue

Return Value

int

at line 70
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 83
string getQueue(string $queue = null)

Get the queue or return the default.

Parameters

string $queue

Return Value

string

at line 120
void run(string|null $queue = null)

Run the worker

Parameters

string|null $queue

Return Value

void