Merge pull request #47 from alessandrodorazio/custom-connection

Custom job dispatch connection

README.md

@@ -59,6 +59,11 @@ return [
      * job to set timeouts, retries, etc...
      */
     'job' => Spatie\DiscordAlerts\Jobs\SendToDiscordChannelJob::class,
+
+    /*
+     * It is possible to specify the queue connection that should be used to send the alert.
+     */
+    'queue_connection' => 'redis',
 ];
 
 ```

src/Config.php

@@ -38,4 +38,15 @@ public static function getWebhookUrl(string $name): string
 
         return $url;
     }
+
+    public static function getConnection(): string
+    {
+        $connection = config("discord-alerts.queue_connection");
+
+        if(is_null($connection)) {
+            $connection = config("queue.default");
+        }
+
+        return $connection;
+    }
 }

src/DiscordAlert.php

@@ -37,7 +37,7 @@ public function message(string $text, array $embeds = []): void
 
         $job = Config::getJob($jobArguments);
 
-        dispatch($job);
+        dispatch($job)->onConnection(Config::getConnection());
     }
 
     private function parseNewline(string $text): string

tests/DiscordAlertsTest.php

@@ -18,6 +18,17 @@
     Bus::assertDispatched(SendToDiscordChannelJob::class);
 });
 
+it('can dispatch a job to send a message to discord using the default webhook url and a custom queue', function () {
+    config()->set('discord-alerts.webhook_urls.default', 'https://test-domain.com');
+    config()->set('discord-alerts.queue_connection', 'custom-queue-connection');
+
+    DiscordAlert::message('test-data');
+
+    Bus::assertDispatched(SendToDiscordChannelJob::class, function ($job) {
+        return $job->connection === 'custom-queue-connection';
+    });
+});
+
 it('can dispatch a job to send a message to discord using an alternative webhook url', function () {
     config()->set('discord-alerts.webhook_urls.marketing', 'https://test-domain.com');