bupy7/zf-queue

Queue module for Zend Framework 3.

zf-queue

, _(*1)

Abstract queue module for Laminas. Module contains only abstract layers to create their own integrations using this module., _(*2)

Installation

The preferred way to install this extension is through composer., _(*3)

Either run, _(*4)

$ php composer.phar require bupy7/zf-queue "*"

or add, _(*5)

"bupy7/zf-queue": "*"

to the require section of your composer.json file., _(*6)

Integration

Ready integrations

• Doctrine 2 ORM

Create their own integration

TODO, _(*7)

Usage

Create task

Let's create our first an example task for queue:, _(*8)

// YourModule/src/task/ExampleTask.php

namespace YourModule\Task;

use Bupy7\Queue\Task\TaskInterface;
use Laminas\Stdlib\ParametersInterface;
use Chat\Service\ChatService;

class SendAccountTask implements TaskInterface
{
    /**
     * @var ChatService
     */
    protected $chatService;

    public function __construct(ChatService $chatService) {
        $this->chatService = $chatService;
    }

    /**
     * @param ParametersInterface $params
     * - message (string)
     * @return bool
     */
    public function execute(ParametersInterface $params): bool
    {
        $this->chatService->send($params->get('message'));
        return true;
    }
}

Run task

After you need to register task to queue manager:, _(*9)

// YouModule/config/queue.config.php

namespace YourModule;

return [
    'queue_manager' => [
        'factories' => [
            Task\ExampleTask::class => \Laminas\ServiceManager\AbstractFactory\ReflectionBasedAbstractFactory::class,
        ],
    ],
];

Now, add queue.config.php to your config list:, _(*10)

// YourModule/src/YourModule.php

class Module
{
    public function getConfig(): array
    {
        return array_merge(

            // another config files

            require __DIR__ . '/../config/queue.config.php'
        );
    }
}

Add the task to queue, _(*11)

$container->get('Bupy7\Queue\Service\QueueService')->add('YourModule\Task\ExampleTask');

Run queue, _(*12)

$container->get('Bupy7\Queue\Service\QueueService')->run();

License

zf-queue is released under the BSD 3-Clause License., _(*13)