home
/
zktecojo
/
public_html
/
vendor
/
laravel
/
framework
/
src
/
Illuminate
/
Queue
➕ New
📤 Upload
✎ Editing:
QueueServiceProvider.php
← Back
<?php namespace Illuminate\Queue; use IlluminateQueueClosure; use Illuminate\Support\ServiceProvider; use Illuminate\Queue\Console\WorkCommand; use Illuminate\Queue\Console\ListenCommand; use Illuminate\Queue\Console\RestartCommand; use Illuminate\Queue\Connectors\SqsConnector; use Illuminate\Queue\Console\SubscribeCommand; use Illuminate\Queue\Connectors\SyncConnector; use Illuminate\Queue\Connectors\IronConnector; use Illuminate\Queue\Connectors\RedisConnector; use Illuminate\Queue\Connectors\BeanstalkdConnector; use Illuminate\Queue\Failed\DatabaseFailedJobProvider; class QueueServiceProvider extends ServiceProvider { /** * Indicates if loading of the provider is deferred. * * @var bool */ protected $defer = true; /** * Register the service provider. * * @return void */ public function register() { $this->registerManager(); $this->registerWorker(); $this->registerListener(); $this->registerSubscriber(); $this->registerFailedJobServices(); $this->registerQueueClosure(); } /** * Register the queue manager. * * @return void */ protected function registerManager() { $this->app->bindShared('queue', function($app) { // Once we have an instance of the queue manager, we will register the various // resolvers for the queue connectors. These connectors are responsible for // creating the classes that accept queue configs and instantiate queues. $manager = new QueueManager($app); $this->registerConnectors($manager); return $manager; }); } /** * Register the queue worker. * * @return void */ protected function registerWorker() { $this->registerWorkCommand(); $this->registerRestartCommand(); $this->app->bindShared('queue.worker', function($app) { return new Worker($app['queue'], $app['queue.failer'], $app['events']); }); } /** * Register the queue worker console command. * * @return void */ protected function registerWorkCommand() { $this->app->bindShared('command.queue.work', function($app) { return new WorkCommand($app['queue.worker']); }); $this->commands('command.queue.work'); } /** * Register the queue listener. * * @return void */ protected function registerListener() { $this->registerListenCommand(); $this->app->bindShared('queue.listener', function($app) { return new Listener($app['path.base']); }); } /** * Register the queue listener console command. * * @return void */ protected function registerListenCommand() { $this->app->bindShared('command.queue.listen', function($app) { return new ListenCommand($app['queue.listener']); }); $this->commands('command.queue.listen'); } /** * Register the queue restart console command. * * @return void */ public function registerRestartCommand() { $this->app->bindShared('command.queue.restart', function() { return new RestartCommand; }); $this->commands('command.queue.restart'); } /** * Register the push queue subscribe command. * * @return void */ protected function registerSubscriber() { $this->app->bindShared('command.queue.subscribe', function() { return new SubscribeCommand; }); $this->commands('command.queue.subscribe'); } /** * Register the connectors on the queue manager. * * @param \Illuminate\Queue\QueueManager $manager * @return void */ public function registerConnectors($manager) { foreach (array('Sync', 'Beanstalkd', 'Redis', 'Sqs', 'Iron') as $connector) { $this->{"register{$connector}Connector"}($manager); } } /** * Register the Sync queue connector. * * @param \Illuminate\Queue\QueueManager $manager * @return void */ protected function registerSyncConnector($manager) { $manager->addConnector('sync', function() { return new SyncConnector; }); } /** * Register the Beanstalkd queue connector. * * @param \Illuminate\Queue\QueueManager $manager * @return void */ protected function registerBeanstalkdConnector($manager) { $manager->addConnector('beanstalkd', function() { return new BeanstalkdConnector; }); } /** * Register the Redis queue connector. * * @param \Illuminate\Queue\QueueManager $manager * @return void */ protected function registerRedisConnector($manager) { $app = $this->app; $manager->addConnector('redis', function() use ($app) { return new RedisConnector($app['redis']); }); } /** * Register the Amazon SQS queue connector. * * @param \Illuminate\Queue\QueueManager $manager * @return void */ protected function registerSqsConnector($manager) { $manager->addConnector('sqs', function() { return new SqsConnector; }); } /** * Register the IronMQ queue connector. * * @param \Illuminate\Queue\QueueManager $manager * @return void */ protected function registerIronConnector($manager) { $app = $this->app; $manager->addConnector('iron', function() use ($app) { return new IronConnector($app['encrypter'], $app['request']); }); $this->registerIronRequestBinder(); } /** * Register the request rebinding event for the Iron queue. * * @return void */ protected function registerIronRequestBinder() { $this->app->rebinding('request', function($app, $request) { if ($app['queue']->connected('iron')) { $app['queue']->connection('iron')->setRequest($request); } }); } /** * Register the failed job services. * * @return void */ protected function registerFailedJobServices() { $this->app->bindShared('queue.failer', function($app) { $config = $app['config']['queue.failed']; return new DatabaseFailedJobProvider($app['db'], $config['database'], $config['table']); }); } /** * Register the Illuminate queued closure job. * * @return void */ protected function registerQueueClosure() { $this->app->bindShared('IlluminateQueueClosure', function($app) { return new IlluminateQueueClosure($app['encrypter']); }); } /** * Get the services provided by the provider. * * @return array */ public function provides() { return array( 'queue', 'queue.worker', 'queue.listener', 'queue.failer', 'command.queue.work', 'command.queue.listen', 'command.queue.restart', 'command.queue.subscribe', ); } }
💾 Save Changes
Cancel
📤 Upload File
×
Select File
Upload
Cancel
➕ Create New
×
Type
📄 File
📁 Folder
Name
Create
Cancel
✎ Rename Item
×
Current Name
New Name
Rename
Cancel
🔐 Change Permissions
×
Target File
Permission (e.g., 0755, 0644)
0755
0644
0777
Apply
Cancel