PHP code example of phpgears / event-async-queue-interop

1. Go to this page and download the library: Download phpgears/event-async-queue-interop 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/ */

phpgears / event-async-queue-interop example snippets





use Gears\Event\Async\AsyncEventBus;
use Gears\Event\Async\QueueInterop\QueueInteropEventQueue;
use Gears\Event\Async\Serializer\JsonEventSerializer;
use Gears\Event\Async\Discriminator\ParameterEventDiscriminator;

/* @var \Gears\Event\EventBus $eventBus */
/* @var \Interop\Queue\PsrContext $context */
/* @var \Interop\Queue\PsrDestination $destination */

$eventQueue = new QueueInteropEventQueue(new JsonEventSerializer(), $context, $destination);

$asyncEventBus = new AsyncEventBus(
    $eventBus,
    $eventQueue,
    new ParameterEventDiscriminator('async')
);

$asyncEvent = CustomEvent::occurred(['async' => true]);

$asyncEventBus->dispatch($asyncEvent);