Quickstart¶

As a Producer¶

// returns BeanstalkPool instance
$bean = (new Beanstalk\Pool)
     ->addServer('localhost', 11300)
     ->useTube('my-tube')
     ->put('Hello World!');

As a Consumer¶

$bean = (new Beanstalk\Pool)
     ->addServer('localhost', 11300)
     ->watchTube('my-tube');

while (true)
{
    try
    {
        $job = $bean->reserve($timeout = 10);

        /* process job ... */

        $job->delete();
    }
    catch (Beanstalk\Exception $e)
    {
        switch ($e->getCode())
        {
            case Beanstalk\Exception::TIMED_OUT:
                echo "Timed out waiting for a job.  Retrying in 1 second."
                sleep(1);
                continue;
                break;

            default:
                throw $e;
                break;
        }
    }
}

Built-in JSON support¶

Objects are automatically converted¶

$bean = (new Beanstalk\Pool)
     ->addServer('localhost', 11300)
     ->useTube('my-tube');

$obj = new stdClass;
$obj->content = 'Hello World!';
$bean->put($obj); // stored in beanstalkd as '{"content":"Hello World!"}'

$bean->watchTube('my-tube');
$job = $bean->reserve();
print_r($job->getMessage());

Outputs:

stdClass Object
(
    [content] => Hello World!
)

Send a custom JSON string¶

$bean = (new Beanstalk\Pool)
     ->addServer('localhost', 11300)
     ->useTube('my-tube')
$bean->put('[123,456,789]');

$bean->watchTube('my-tube');
$job = $bean->reserve();
print_r($job->getMessage());

Outputs:

Array
(
    [0] => 123
    [1] => 456
    [2] => 789
)

Table Of Contents

Quickstart

Previous topic

PHP Beanstalkd Client documentation

Next topic

Beanstalkd Client Class Refs

This Page