QueueServiceProvider.php 700 B

1234567891011121314151617181920212223242526272829303132
  1. <?php
  2. namespace app\common\providers;
  3. use app\framework\Queue\Worker;
  4. use Illuminate\Contracts\Debug\ExceptionHandler;
  5. class QueueServiceProvider extends \Illuminate\Queue\QueueServiceProvider
  6. {
  7. /**
  8. * Register the queue worker.
  9. *
  10. * @return void
  11. */
  12. protected function registerWorker()
  13. {
  14. $this->app->singleton('queue.worker', function () {
  15. $isDownForMaintenance = function () {
  16. return $this->app->isDownForMaintenance();
  17. };
  18. return new Worker(
  19. $this->app['queue'],
  20. $this->app['events'],
  21. $this->app[ExceptionHandler::class],
  22. $isDownForMaintenance
  23. );
  24. });
  25. }
  26. }