vklymniuk/common-bus

Command bus.

This package's canonical repository appears to be gone and the package has been frozen as a result.

v0.0.1 2021-05-24 18:07 UTC

Requires

• php: >=7.4
• psr/log: ^1.1

Requires (Dev)

• roave/security-advisories: dev-master

MIT

• Vladimir Klymniuk

• php
• middleware
• common-bus

README

Communication system that transfers message data between custom middleware.

Install

$ composer require symfony-ext/common-bus

Register the bundle:

// config/bundles.php

return [
    ...
    VKCommonBusBundle\VKCommonBusBundle::class => ['all' => true],
];

Create your bus

<?php

namespace App\CommandBus;

use VKCommonBusBundle\AbstractCommonBus;

/**
 * Class MetadataCollectorCommonBus
 */
class MetadataCollectorCommonBus extends AbstractCommonBus
{
    /**
     * @return string Supported Message class name
     */
    public function supports(): string
    {
        return \App\Document\Metadata::class;
    }
}

Create bus middleware

<?php

use VKCommonBusBundle\Envelope;
use VKCommonBusBundle\Middleware\MiddlewareInterface;
use VKCommonBusBundle\Stack\StackInterface;

/**
 * Class SearchMetadataMiddleware
 */
class SearchMetadataMiddleware implements MiddlewareInterface
{
    /**
     * @inheritdoc
     */
    public function handle(Envelope $envelope, StackInterface $stack): Envelope
    {
        /** @var \App\Document\Metadata $message */
        $message = $envelope->getMessage();
        // Your code

        return $stack->next()->handle($envelope, $stack);
    }
}

Register bus middleware handles

    App\CommonBus\MetadataCollectorCommandBus:
        arguments:
            $middlewareHandlers:
                - '@App\CommonBus\Middleware\SearchMetadataMiddleware'
                - '@App\CommonBus\Middleware\SearchMetadataMiddleware_1'
                - '@App\CommonBus\Middleware\SearchMetadataMiddleware_2'
                - '@App\CommonBus\Middleware\SearchMetadataMiddleware_3'
                - '@App\CommonBus\Middleware\SearchMetadataMiddleware_4'

Enjoy!