protected function registerCouchbaseQueueDriver(): void
    {
        /** @var QueueManager $queueManager */
        $queueManager = $this->app['queue'];
        $queueManager->addConnector('couchbase', function () {
            /** @var DatabaseManager $databaseManager */
            $databaseManager = $this->app['db'];

            return new QueueConnector($databaseManager);
        });
    }
protected function registerCouchbaseQueueDriver(): void
    {
        /** @var QueueManager $queueManager */
        $queueManager = $this->app['queue'];
        $queueManager->addConnector('couchbase', function () {
            /** @var DatabaseManager $databaseManager */
            $databaseManager = $this->app['db'];

            return new QueueConnector($databaseManager);
        });
    }
protected function registerCouchbaseQueueDriver ( ) : void { /** @var QueueManager $queueManager */ $ queueManager = $ this -> app [ 'queue' ] ; $ queueManager -> addConnector ( 'couchbase' , function ( ) { /** @var DatabaseManager $databaseManager */ $ databaseManager = $ this -> app [ 'db' ] ; return new QueueConnector ( $ databaseManager ) ; } ) ; }
register custom queue 'couchbase' driver
register custom queue couchbase driver