symfony
diff --git a/‎src/Symfony/Component/Messenger/Bridge/AmazonSqs/Tests/Transport/AmazonSqsQueryStringParserTest.php
Copy file name to clipboard
+37Lines changed: 37 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/AmazonSqs/Tests/Transport/AmazonSqsQueryStringParserTest.php
Copy file name to clipboard
+37Lines changed: 37 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/AmazonSqsQueryStringParser.php
Copy file name to clipboard
+35Lines changed: 35 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/AmazonSqsQueryStringParser.php
Copy file name to clipboard
+35Lines changed: 35 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/Connection.php
+1-4Lines changed: 1 addition & 4 deletions b/‎src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/Connection.php
+1-4Lines changed: 1 addition & 4 deletions
@@ -0,0 +1,37 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <fabien@symfony.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\Component\Messenger\Bridge\AmazonSqs\Tests\Transport;
+
+use PHPUnit\Framework\TestCase;
+use Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsQueryStringParser;
+
+class AmazonSqsQueryStringParserTest extends TestCase
+{
+    public function testParse()
+    {
+        $queryStrings = 'access_key=1&secret_key=A+a+B+b&region=[\^$.|?*+-*${}/?!"%()&queue_name=';
+
+        $SUT = $this->getSUT();
+        $actual = $SUT->parse($queryStrings);
+
+        $this->assertCount(4, $actual);
+        $this->assertSame('1', $actual['access_key']);
+        $this->assertSame('A+a+B+b', $actual['secret_key']);
+        $this->assertSame('[\^$.|?*+-*${}/?!"%()', $actual['region']);
+        $this->assertSame('', $actual['queue_name']);
+    }
+
+    private function getSUT()
+    {
+        return new AmazonSqsQueryStringParser();
+    }
+}
@@ -0,0 +1,35 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <fabien@symfony.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\Component\Messenger\Bridge\AmazonSqs\Transport;
+
+/**
+ * @author Yukihiro Arisawa <goreboothero@gmail.com>
+ */
+class AmazonSqsQueryStringParser
+{
+    public function parse(string $queryString): array
+    {
+        $query = [];
+
+        foreach (explode('&', $queryString) as $targetQueryString) {
+            $queryStringArray = explode('=', $targetQueryString);
+            $key = $queryStringArray[0] ?? '';
+            $value = $queryStringArray[1] ?? '';
+
+            if ($key !== '') {
+                $query[$key] = $value;
+            }
+        }
+
+        return $query;
+    }
+}
@@ -110,10 +110,7 @@ public static function fromDsn(string $dsn, array $options = [], HttpClientInter
 
         $query = [];
         if (isset($parsedUrl['query'])) {
-            foreach (explode('&', $parsedUrl['query']) as $queryParameter) {
-                $queryParameterArray = explode('=', $queryParameter);
-                $query[$queryParameterArray[0]] = $queryParameterArray[1];
-            }
+            $query = (new AmazonSqsQueryStringParser())->parse($parsedUrl['query']);
         }
 
         // check for extra keys in options