php-background-job-gist1.php

<?php

use Bernard\Message\PlainMessage;
use Bernard\Producer;
use Bernard\QueueFactory\PersistentFactory;
use Bernard\Serializer;
use Symfony\Component\EventDispatcher\EventDispatcher;

//.. create $driver
$queueFactory = new PersistentFactory($driver, new Serializer());
$eventDispatcher = new EventDispatcher();
$producer = new Producer($queueFactory, $eventDispatcher);

$message = new PlainMessage('SendForgotPasswordEmail', array(
    'user_id' => 12,
));

$producer->produce($message, 'emails');