Skip to content

Commit 1249b39

Browse files
committed
Fixed checking connections
1 parent 2b78e26 commit 1249b39

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/SqsQueueReaderServiceProvider.php

+2-3
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,8 @@ public function boot(): void
2424
], 'config');
2525

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

0 commit comments

Comments
 (0)