Merge pull request #35 from joblocal/bugfix/handle-topic-arn-and-subj…

…ect-when-checking-routes

also check for topic arn when checking if routes are set

src/Queue/SqsSnsQueue.php

@@ -78,7 +78,15 @@ protected function routeExists(array $message)
     {
         $body = json_decode($message['Body'], true);
 
-        return isset($body['Subject']) && array_key_exists($body['Subject'], $this->routes);
+        $possibleRouteParams = ['Subject', 'TopicArn'];
+
+        foreach ($possibleRouteParams as $param) {
+            if (isset($body[$param]) && array_key_exists($body[$param], $this->routes)) {
+                return true;
+            }
+        }
+
+        return false;
     }
 
     /**