treehouselabs/worker-bundle

Adds worker functionality to a Symfony2 project, using Beanstalkd as the message queue

Deprecated & archived

This bundle is no longer maintained. It will still work with Symfony versions ^2.8|^3.0|^4.0 and is archived here to not break existing applications using it. However it will not get maintenance updates or even security fixes., _(*1)

If you need queue/worker functionality in your project, there are far better solutions right now to look at:, _(*2)

• https://github.com/symfony/messenger/
• https://github.com/php-enqueue/enqueue-dev

Previous readme below 👇, _(*3)

Worker bundle

![Software License][ico-license] ![Coverage Status][ico-scrutinizer] , _(*4)

A Symfony bundle that adds worker functionality to your project, using Beanstalkd as the message queue., _(*5)

Installation

For this process, we assume you have a Beanstalk server up and running., _(*6)

Install via Composer:, _(*7)

$ composer require treehouselabs/worker-bundle

Enable the bundle:, _(*8)

# app/AppKernel.php
class AppKernel extends Kernel
{
    public function registerBundles()
    {
        $bundles = [
            // ...

            new TreeHouse\WorkerBundle\TreeHouseWorkerBundle(),
        ];

        // ...
    }

    // ...
}

Configuration

Define a queue and you're good to go:, _(*9)

# app/config/config.yml

tree_house_worker:
  queue:
    server: localhost

The bundle also supports the PheanstalkBundle, if you're using that:, _(*10)

# app/config/config.yml

tree_house_worker:
  pheanstalk: leezy.pheanstalk

Basic Usage

The bundle creates a QueueManager service, which you can use to manage jobs. The manager has services registered to execute specific tasks, called executors. An executor receives a job from the QueueManager and processes it., _(*11)

Defining executors

First you need to register an executor, and tag it as such:, _(*12)

# src/AppBundle/Executor/HelloWorldExecutor.php

use TreeHouse\WorkerBundle\Executor\AbstractExecutor;

class HelloWorldExecutor extends AbstractExecutor
{
    public function getName()
    {
        return 'hello.world';
    }

    public function configurePayload(OptionsResolver $resolver)
    {
        $resolver->setRequired(0);
    }

    public function execute(array $payload)
    {
        $name = array_shift($payload);

        # process stuff here, in this example we just print something
        echo 'Hello, ' . $name;

        return true;
    }
}

# app/config/services.yml
app.executor.hello_world:
  class: AppBundle/Executor/HelloWorldExecutor
  tags:
    - { name: tree_house.worker.executor }

Scheduling jobs

Now you can add jobs, either via code or using the worker:schedule command:, _(*13)

In your application's code:, _(*14)

$queueManager = $container->get('tree_house.worker.queue_manager');
$queueManager->add('hello.world', ['Peter']);

Using the command:, _(*15)

php app/console worker:schedule hello.world Peter

Working jobs

A worker can now receive and process these jobs via the console:, _(*16)

php app/console worker:run

# prints:
# Working hello.world with payload ["Peter"]
# Hello, Peter
# Completed job in 1ms with result: true

You can run workers by adding them to your crontab, creating a Supervisor program for it, or whatever your preferred method is., _(*17)

Documentation

1. Message queues & workers
2. The QueueManager
3. Executors
4. Working jobs

Security

If you discover any security related issues, please email dev@treehouse.nl instead of using the issue tracker., _(*18)

License

The MIT License (MIT). Please see License File for more information., _(*19)

Credits

• Peter Kruithof
• All Contributors