params.php

<?php

declare(strict_types=1);

use Yiisoft\Queue\Command\ConsumeCommand;
use Yiisoft\Queue\Debug\QueueCollector;
use Yiisoft\Queue\Debug\QueueConsumerProviderProxy;
use Yiisoft\Queue\Debug\QueueProducerProviderProxy;
use Yiisoft\Queue\Debug\QueueWorkerInterfaceProxy;
use Yiisoft\Queue\Message\Handler\HandlerInterface;
use Yiisoft\Queue\Message\Serializer\MessageSerializer;
use Yiisoft\Queue\Provider\QueueConsumerProviderInterface;
use Yiisoft\Queue\Provider\QueueProducerProviderInterface;
use Yiisoft\Queue\Worker\WorkerInterface;

return [
    'yiisoft/yii-console' => [
        'commands' => [
            'queue:consume' => ConsumeCommand::class,
        ],
    ],
    'yiisoft/queue' => [
        /**
         * Map of message type to message class. Used by {@see MessageSerializer} to reconstruct the original typed
         * message object on unserialize. Example:
         * [
         *     'send-email' => SendEmailMessage::class,
         *     'generate-report' => GenerateReportMessage::class,
         * ]
         */
        'messages' => [],
        /**
         * Map of message type to handler. The worker uses this to find the handler for a received message.
         * A handler may be a class name implementing {@see HandlerInterface}, a callable, or any definition
         * supported by yiisoft/injector. Example:
         * [
         *     'send-email' => SendEmailHandler::class,
         *     'generate-report' => [GenerateReportHandler::class, 'handle'],
         * ]
         */
        'handlers' => [],
        'middlewares-push' => [],
        'middlewares-consume' => [],
        'middlewares-fail' => [],
    ],
    'yiisoft/yii-debug' => [
        'collectors' => [
            QueueCollector::class,
        ],
        'trackedServices' => [
            QueueProducerProviderInterface::class => [QueueProducerProviderProxy::class, QueueCollector::class],
            QueueConsumerProviderInterface::class => [QueueConsumerProviderProxy::class, QueueCollector::class],
            WorkerInterface::class => [QueueWorkerInterfaceProxy::class, QueueCollector::class],
        ],
    ],
];