composer require freyo/laravel-queue-cmq

'providers' => [
  // ...
  Freyo\LaravelQueueCMQ\LaravelQueueCMQServiceProvider::class,
]

QUEUE_DRIVER=cmq

CMQ_SECRET_KEY=
CMQ_SECRET_ID=

CMQ_QUEUE_HOST=https://cmq-queue-{region}.api.qcloud.com
CMQ_QUEUE=queue_name # имя очереди по умолчанию
CMQ_QUEUE_POLLING_WAIT_SECONDS=0
```CMQ_TOPIC_ENABLE=false # Установите значение в true для использования темы
CMQ_TOPIC_FILTER=routing # или msgtag
CMQ_TOPIC_HOST=https://cmq-topic-{region}.api.qcloud.com
CMQ_TOPIC=topic_name

// использование только очереди
Job::dispatch()->onConnection('connection-name')->onQueue('queue-name');
// или dispatch((new Job())->onConnection('connection-name')->onQueue('queue-name'))

// использование темы и фильтра тегов
Job::dispatch()->onConnection('connection-name')->onQueue('tag1,tag2,tag3');
// или dispatch((new Job())->onConnection('connection-name')->onQueue('tag1,tag2,tag3'))

// использование темы и фильтра маршрутизации
Job::dispatch()->onConnection('connection-name')->onQueue('routing-key');
// или dispatch((new Job())->onConnection('connection-name')->onQueue('routing-key'))

```bash
php artisan queue:work {connection-name} --queue={queue-name}

CMQ_PLAIN_ENABLE=true
CMQ_PLAIN_JOB=App\Jobs\CMQPlainJobHandler@handle

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Freyo\LaravelQueueCMQ\Queue\Contracts\PlainPayload;

class CMQPlainJob implements ShouldQueue, PlainPayload
{
    use Dispatchable, InteractsWithQueue, Queueable;
    
    protected $payload;

    /**
     * Создает новый экземпляр задачи.
     *
     * @param string $payload
     */
    public function __construct($payload)
    {
        $this->payload = $payload;
    }
    
    /**
     * Получает простой пейлоад задачи.
     *
     * @return string
     */
    public function getPayload()
    {
        return $this->payload;
    }
}

<?php

namespace App\Jobs;

use Illuminate\Queue\Jobs\Job;

class CMQPlainJobHandler
{
    /**
     * Выполняет задачу.
     * 
     * @param \Illuminate\Queue\Jobs\Job $job
     * @param string $payload
     * 
     * @return void
     */
    public function handle(Job $job, $payload)
    {
        // обработка вашего пейлоада...
        var_dump($payload);
        
        // возврат в очередь при неудаче.
        // $job->release();
        
        // удаление сообщения после обработки.
        if (! $job->isDeletedOrReleased()) {
            $job->delete();
        }        
    }
}