memory.md

Memory queue

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

Memory queue stores events in an internal variable, which allows you to delay execution of events at the end of the script execution.

use GpsLab\Domain\Event\Queue\Pull\MemoryPullEventQueue;

$queue = new MemoryPullEventQueue();

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

$queue->publish($event);

In latter you can pull events from queue

use GpsLab\Domain\Event\Bus\ListenerLocatedEventBus;
use GpsLab\Domain\Event\Listener\Locator\DirectBindingEventListenerLocator;

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

while ($event = $queue->pull()) {
    $bus->publish($event);
}

You can use QueueEventBus for publish events in queue.