PHP code example of wildfire / pipeline_processor

1. Go to this page and download the library: Download wildfire/pipeline_processor library. Choose the download type require.

2. Extract the ZIP file and open the index.php.

3. Add this code to the index.php. 
    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

wildfire / pipeline_processor example snippets



\PipelineProcessor\PipelineProcessor;
use \PipelineProcessor\Handler\OrderHandler;
use \PipelineProcessor\Handler\PayHandler;
use \PipelineProcessor\Registry;

// 创建一些处理器
$order = new OrderHandler();
$pay = new PayHandler();

//创建一些通道
$application = new PipelineProcessor('application');
$api = new PipelineProcessor('api');

// 或者克隆第一个，只是改变下通道
$security = $api->withName('security');

//对通道应用哪些处理器
$application->pushHandler($pay);
$api->pushHandler($pay);
$security->pushHandler($pay);

$application1 = $application->withName('application1');
$api1 = $application->withName('api1');

//通道的另一种调用方式
Registry::addLogger($application1);
Registry::addLogger($api1);

//通道开始处理
$application->info('application');
$api->info('api');
$security->info('security');

Registry::application1()->info('application1');
Registry::api1()->info('api1');
Registry::clear();




namespace PipelineProcessor\Handler;

use PipelineProcessor\Handler\AbstractHandler;

// 必须继承PipelineProcessor\Handler\AbstractHandler, 并实现方法perform
class OrderHandler extends AbstractHandler
{
    protected function perform($record)
    {
        $this->getLogger()->info($record);
    }
}