1. Go to this page and download the library: Download kinetis/queue-sql 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/ */
kinetis / queue-sql example snippets
use Kinetis\Config\Config;
use Kinetis\QueueSql\SqlQueueFactory;
$queue = SqlQueueFactory::fromConfig($config);
$queue->push(new SendWelcomeEmail($email, $name), queue: 'default');
use Kinetis\Persistence\Contract\SqlTransaction;
$guard->transaction($link, function (SqlTransaction $tx) use ($queue, $orderId): void {
$tx->execute('UPDATE orders SET status = ? WHERE id = ?', ['paid', $orderId]);
$queue->pushOn($tx, new SendReceipt($orderId));
});
use Kinetis\Queue\QueueInterface;
use Kinetis\QueueSql\SqlQueue;
use Kinetis\QueueSql\SqlQueueFactory;
$queue = SqlQueueFactory::fromConfig($config);
$app->instance(SqlQueue::class, $queue);
$app->instance(QueueInterface::class, $queue);
$app->onDispose($queue->dispose(...));