executing.md

Executing queue

Queues are designed to distribute the load and delay publishing of events or transfer their publishing to separate processes.

The handler signed to the event from the executing queue immediately receives the event as it published the queue. Events are not stored in the queue.

You can use any implementations of callable type as a queue subscriber.

use GpsLab\Domain\Event\Bus\ListenerLocatedEventBus;
use GpsLab\Domain\Event\Listener\Locator\DirectBindingEventListenerLocator;
use GpsLab\Domain\Event\Queue\Subscribe\ExecutingSubscribeEventQueue;

$locator = new DirectBindingEventListenerLocator();
$bus = new ListenerLocatedEventBus($locator);
$queue = new ExecutingSubscribeEventQueue();

Subscribe to the queue:

$handler = function(ArticleRenamedEvent $event) use ($bus) {
    $bus->publish($event);
};

$queue->subscribe($handler);

You can unsubscribe of the queue:

$queue->unsubscribe($handler);

Make event and publish it into queue:

$event = new ArticleRenamedEvent();
$event->new_name = $new_name;

$queue->publish($event);

You can use QueueEventBus for publish events in queue.