Skip to content

Commit 2b78e26

Browse files
committed
Removed hard coded queue names
1 parent d6a6920 commit 2b78e26

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/SqsQueueReaderServiceProvider.php

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,10 @@ public function boot(): void
2424
], 'config');
2525

2626
Queue::after(function (JobProcessed $event) {
27-
if ($event->connectionName === 'sqs-json' || $event->connectionName === 'sqs-mailgun' || $event->connectionName === 'sqs-external-customer-webhook' || $event->connectionName === 'sqs-priority-json') {
27+
$queueNames = Config::get('sqs-queue-reader.handlers');
28+
$queueNames = array_keys($queueNames);
29+
if (in_array($event->connectionName, $queueNames, true)) {
30+
//if ($event->connectionName === 'sqs-json' || $event->connectionName === 'sqs-mailgun' || $event->connectionName === 'sqs-external-customer-webhook' || $event->connectionName === 'sqs-priority-json') {
2831
$queue = $event->job->getQueue();
2932

3033
$queueId = explode('/', $queue);

0 commit comments

Comments
 (0)