README

此包允许您将进程包中的任务连接到一些启动进程的消费者。这允许多线程/并行化进程。

重要提示

使用事件来通知消费者发生了某些事情，当您想等待动作的结果时使用命令。

您需要在配置中静态地将主题和命令映射到本包的消费者，否则它将没有任何通知地简单地不工作。

快速示例

clever_age_process:
    configurations:
        # This process will dispatch events to the queue in a specific topic
        import.csv:
            tasks:
                # ...
                # Series of tasks that output an scalar or an array of scalar
                push_event:
                    service: '@CleverAge\EnqueueProcessBundle\Task\PushEventTask'
                    options:
                        topic: import_denormalize
        
        # This process will receive the output of the previous process through the queue
        import.denormalize:
            tasks:
                # This is just an example
                denormalize:
                    service: '@CleverAge\ProcessBundle\Task\Serialization\DenormalizerTask'
                    options:
                        class: Foo\Bar
                    outputs: [...] # Do stuff

clever_age_process_enqueue:
    topics:
        import_denormalize: # Map a topic to a process
            process: import.denormalize

cleverage / enqueue-process-bundle

维护者

详细信息

README

重要提示

快速示例