bakaphp / phalcon-api

library/Providers/QueueProvider.php

<?php

namespace Gewaer\Providers;

use Phalcon\Di\ServiceProviderInterface;
use Phalcon\DiInterface;
use function Gewaer\Core\envValue;

class QueueProvider implements ServiceProviderInterface
{
    /**
     * @param DiInterface $container
     */
    public function register(DiInterface $container)
    {
        // $container->setShared(
        //     'queue',
        //     function () {
        //         //Connect to the queue
        //         $queue = new \PhpAmqpLib\Connection\AMQPStreamConnection(
        //             envValue('RABBITMQ_HOST'),
        //             envValue('RABBITMQ_PORT'),
        //             envValue('RABBITMQ_DEFAULT_USER'),
        //             envValue('RABBITMQ_DEFAULT_PASS')
        //         );

        //         return $queue;
        //     }
        // );

        $container->setShared(
            'queue',
            function () {
                //Connect to the queue
                $queue = new Beanstalk([

The type Gewaer\Providers\Beanstalk was not found. Maybe you did not declare it correctly or list all dependencies?

                    'host' => envValue('DATA_API_BEANSTALK_HOST', '127.0.0.1'),
                    'prefix' => envValue('DATA_API_BEANSTALK_PORT', 11300),
                ]);
                return $queue;
            }
        );
    }
}