Wrap AsyncAws Exceptions for "reset" and "setup"

jderusse · jderusse · commit 69a06e760bd4 · 2020-05-03T17:46:28.000+02:00
diff --git a/src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/AmazonSqsTransport.php b/src/Symfony/Component/Messenger/Bridge/AmazonSqs/Transport/AmazonSqsTransport.php
@@ -11,7 +11,9 @@
 
 namespace Symfony\Component\Messenger\Bridge\AmazonSqs\Transport;
 
+use AsyncAws\Core\Exception\Http\HttpException;
 use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Exception\TransportException;
 use Symfony\Component\Messenger\Transport\Serialization\PhpSerializer;
 use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
 use Symfony\Component\Messenger\Transport\SetupableTransportInterface;
@@ -71,12 +73,20 @@ public function send(Envelope $envelope): Envelope
      */
     public function setup(): void
     {
-        $this->connection->setup();
+        try {
+            $this->connection->setup();
+        } catch (HttpException $e) {
+            throw new TransportException($e->getMessage(), 0, $e);
+        }
     }
 
     public function reset()
     {
-        $this->connection->reset();
+        try {
+            $this->connection->setup();
+        } catch (HttpException $e) {
+            throw new TransportException($e->getMessage(), 0, $e);
+        }
     }
 
     private function getReceiver(): AmazonSqsReceiver
