PHP code example of yiisolutions / yii2-queue

1. Go to this page and download the library: Download yiisolutions/yii2-queue 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/ */

yiisolutions / yii2-queue example snippets




return [
    // ...
    'components' => [
        // ...
        'queue' => [
            'class' => 'yisolutions\queue\Queue',
            'host' => 'localhost',
            'port' => 5672,
            'user' => 'guest',
            'password' => 'guest',
            'vhost' => '/',
        ],
        // ...
    ],
    // ...
];




use yiisolutions\queue\Queue;

// ...
$data = ['foo' => 'bar'];

/** @var Queue $queue */
$queue = Yii::$app->get('queue');
$queue->send('queue.name', $data);




use yiisolutions\queue\Queue;
use PhpAmqpLib\Message\AMQPMessage;

// ...
/** @var Queue $queue */
$queue = Yii::$app->get('queue');
$queue->listen('queue.name', function(AMQPMessage $msg) use ($queue) {
    // process data
    
    // acknowledgment message
    $queue->acknowledgmentMessage($msg);
});