classe BeanstalkdAdapter étends QueueAdapter (Voir la source)

Méthodes

string
serializeProducer(ProducerService $producer)

Create producer serialization

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

Détails

string serializeProducer(ProducerService $producer)

Create producer serialization

Paramètres

ProducerService $producer

Valeur de retour

string

configure(array $queue)

Configure Beanstalkd driver

Paramètres

array $queue

setWatch(string $name)

Get connexion

Paramètres

string $name

setRetry(int $retry)

Get connexion

Paramètres

int $retry

push(ProducerService $producer)

Queue a job

Paramètres

ProducerService $producer

size(string $queue = null)

Get the size of the queue.

Paramètres

string $queue

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

Delete a message from the Beanstalk queue.

Paramètres

string $queue
string|int $id

Valeur de retour

void

string getQueue(string $queue = null)

Get the queue or return the default.

Paramètres

string $queue

Valeur de retour

string

run(string $queue = null)

Run the worker

Paramètres

string $queue