class BeanstalkdAdapter extends QueueAdapter (View source)

Methods

string
serializeProducer(ProducerService $producer)

Create producer serialization

unserializeProducer(string $producer)

Create producer unserialize

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

string serializeProducer(ProducerService $producer)

Create producer serialization

Parameters

ProducerService $producer

Return Value

string

ProducerService unserializeProducer(string $producer)

Create producer unserialize

Parameters

string $producer

Return Value

ProducerService

QueueAdapter configure(array $queue)

Configure Beanstalkd driver

Parameters

array $queue

Return Value

QueueAdapter

void setWatch(string $name)

Get connexion

Parameters

string $name

Return Value

void

void setRetry(int $retry)

Get connexion

Parameters

int $retry

Return Value

void

void push(ProducerService $producer)

Queue a job

Parameters

ProducerService $producer

Return Value

void

int size(string $queue = null)

Get the size of the queue.

Parameters

string $queue

Return Value

int

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

Delete a message from the Beanstalk queue.

Parameters

string $queue
string|int $id

Return Value

void

string getQueue(string $queue = null)

Get the queue or return the default.

Parameters

string $queue

Return Value

string

void run(string|null $queue = null)

Run the worker

Parameters

string|null $queue

Return Value

void