arko/queue-manager-bundle

允许您使用单例服务创建和处理可调用队列

安装次数: 6,612

依赖: 0

建议: 0

安全: 0

星星: 0

关注者: 2

分支: 0

类型:symfony-bundle

dev-master 2015-06-26 21:32 UTC

This package is not auto-updated.

Last update: 2024-09-28 17:49:05 UTC


README

如何安装

步骤 1: 使用composer下载

composer.phar require arko/queue-manager-bundle "dev-master"

步骤 2: 启用bundle

<?php
// app/AppKernel.php

public function registerBundle() {
    $bundles = array(
        // ...
        new Arko\QueueManagerBundle\ArkoQueueManagerBundle(),
    );
}

如何使用

您应该能够从服务容器中获取队列管理器服务,如下所示

$queueManager = $container->get('arko.queue_manager');

或者,像往常一样,您可以使用其ID arko.queue_manager 在自己的服务定义中注入它。

从现在起,您可以使用它向命名队列添加不同的操作

$queueManager->add(function() {
    // Do something here
}, 'queue_name');

// ...

$queueManager->add(function() {
    // Do something else, maybe somewhere else.
}, 'queue_name');

将任何PHP可调用对象作为队列管理器添加方法的第一个参数提供。

稍后您将能够这样处理队列

$queueManager->process('queue_name');

队列处理完成后,它将被清除。一般来说,它将在处理队列之前被清除。因此,嵌套队列应该能够正常工作。