rabbitmqTopic: Delete exchange on channel reopenning callback

Flared · Aug 5, 2024 · 9896dc4 · 9896dc4
1 parent eb2386c
commit 9896dc4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/saturn_engine/worker/topics/rabbitmq.py b/src/saturn_engine/worker/topics/rabbitmq.py
@@ -301,6 +301,9 @@ def channel_closed(
             self.logger.error("Channel closed: %s", reason, extra=extra)
 
     def channel_reopened(self, channel: aio_pika.abc.AbstractChannel) -> None:
+        del self.queue
+        del self.exchange
+
         self.logger.info(
             "Channel reopening", extra={"data": {"topic": {"id": self.name}}}
         )