no need to re-declare exchanges which should always exist at this point

Author: BioWilko

varys/consumer.py

@@ -104,12 +104,6 @@ def run(self):
                         f"Queue {self._queue} does not exist, creating it..."
                     )
                     self._channel = self._connection.channel()
-                    self._channel.exchange_declare(
-                        exchange=self._exchange,
-                        exchange_type=self._exchange_type,
-                        durable=True,
-                        passive=True,
-                    )
                     self._channel.queue_declare(queue=self._queue, durable=True)
 
                 self._channel.queue_bind(

varys/producer.py

@@ -128,12 +128,6 @@ def run(self):
                         f"Queue {self._queue} does not exist, creating it..."
                     )
                     self._channel = self._connection.channel()
-                    self._channel.exchange_declare(
-                        exchange=self._exchange,
-                        exchange_type=self._exchange_type,
-                        durable=True,
-                        passive=True,
-                    )
                     self._channel.queue_declare(queue=self._queue, durable=True)
 
                 self._channel.queue_bind(