implements route key TopicArn, Subject

joblocal · Jan 24, 2018 · 93d9d3c · 93d9d3c
1 parent 1470055
commit 93d9d3c
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/src/Queue/Jobs/SqsSnsJob.php b/src/Queue/Jobs/SqsSnsJob.php
@@ -37,10 +37,20 @@ private function resolveSnsSubscription(array $job, array $routes)
     {
         $body = json_decode($job['Body'], true);
 
-        if (isset($body['Subject']) && array_key_exists($body['Subject'], $routes)) {
-            // Find name of command in queue routes
-            $commandName = $routes[$body['Subject']];
+        $commandName = null;
 
+        // available parameters to route your jobs by
+        $possibleRouteParams = ['TopicArn', 'Subject'];
+
+        foreach ($possibleRouteParams as $param) {
+            if (isset($body[$param]) && array_key_exists($body[$param], $routes)) {
+                // Find name of command in queue routes using the param field
+                $commandName = $routes[$body[$param]];
+                break;
+            }
+        }
+
+        if ($commandName !== null) {
             // restructure job body
             $job['Body'] = json_encode([
                 'job' => CallQueuedHandler::class . '@call',