feat: Restart the queue worker after cache clearing, ext enable/disable, save settings

framework/core/src/Queue/QueueRestarter.php

@@ -0,0 +1,57 @@
+<?php
+
+/*
+ * This file is part of Flarum.
+ *
+ * For detailed copyright and license information, please view the
+ * LICENSE file that was distributed with this source code.
+ */
+
+namespace Flarum\Queue;
+
+use Flarum\Extension\Event\Disabled;
+use Flarum\Extension\Event\Enabled;
+use Flarum\Foundation\Event\ClearingCache;
+use Flarum\Settings\Event\Saved;
+use Illuminate\Contracts\Container\Container;
+use Illuminate\Contracts\Events\Dispatcher;
+use Illuminate\Queue\Console\RestartCommand;
+use Symfony\Component\Console\Input\ArrayInput;
+use Symfony\Component\Console\Output\NullOutput;
+
+class QueueRestarter
+{
+    /**
+     * @var Container
+     */
+    protected $container;
+
+    /**
+     * @var RestartCommand
+     */
+    protected $command;
+
+    public function __construct(Container $container, RestartCommand $command)
+    {
+        $this->container = $container;
+        $this->command = $command;
+    }
+
+    public function subscribe(Dispatcher $events)
+    {
+        $events->listen([
+            ClearingCache::class, Saved::class,
+            Enabled::class, Disabled::class
+        ], [$this, 'restart']);
+    }
+
+    public function restart()
+    {
+        $this->command->setLaravel($this->container);
+
+        $this->command->run(
+            new ArrayInput([]),
+            new NullOutput
+        );
+    }
+}

framework/core/src/Queue/QueueServiceProvider.php

@@ -161,5 +161,7 @@ public function boot(Dispatcher $events, Container $container)
                 }
             }
         });
+
+        $events->subscribe(QueueRestarter::class);
     }
 }