Refactor: Remove magic methods for hashing, use names for queue/exchange

faststream/rabbit/helpers/declarer.py

@@ -12,8 +12,8 @@ class RabbitDeclarer:
     """An utility class to declare RabbitMQ queues and exchanges."""
 
     def __init__(self) -> None:
-        self.__queues: dict[RabbitQueue, aio_pika.RobustQueue] = {}
-        self.__exchanges: dict[RabbitExchange, aio_pika.RobustExchange] = {}
+        self.__queues: dict[str, aio_pika.RobustQueue] = {}
+        self.__exchanges: dict[str, aio_pika.RobustExchange] = {}
 
         self.__connection: ConnectionState = EmptyConnectionState()
 
@@ -36,8 +36,8 @@ async def declare_queue(
         passive: bool = False,
     ) -> "aio_pika.RobustQueue":
         """Declare a queue."""
-        if (q := self.__queues.get(queue)) is None:
-            self.__queues[queue] = q = cast(
+        if (q := self.__queues.get(queue.name)) is None:
+            self.__queues[queue.name] = q = cast(
                 "aio_pika.RobustQueue",
                 await self.__connection.channel.declare_queue(
                     name=queue.name,
@@ -50,8 +50,11 @@ async def declare_queue(
                     robust=queue.robust,
                 ),
             )
-
-        return q
+        if all([getattr(queue, attr)==getattr(q, attr) for attr in ["name", "durable", "exclusive", "passive",
+                                                                    "auto_delete", "arguments"]]):
+            return q
+        else:
+            raise ValueError("Queue mismatch")
 
     async def declare_exchange(
         self,
@@ -62,8 +65,8 @@ async def declare_exchange(
         if not exchange.name:
             return self.__connection.channel.default_exchange
 
-        if (exch := self.__exchanges.get(exchange)) is None:
-            self.__exchanges[exchange] = exch = cast(
+        if (exch := self.__exchanges.get(exchange.name)) is None:
+            self.__exchanges[exchange.name] = exch = cast(
                 "aio_pika.RobustExchange",
                 await self.__connection.channel.declare_exchange(
                     name=exchange.name,
@@ -87,5 +90,7 @@ async def declare_exchange(
                     timeout=exchange.timeout,
                     robust=exchange.robust,
                 )
-
-        return exch
+        if self.__exchanges[exchange.name]==exch:
+            return exch
+        else:
+            raise ValueError("Exchange mismatch")

faststream/rabbit/schemas/exchange.py

@@ -36,18 +36,6 @@ def __repr__(self) -> str:
 
         return f"{self.__class__.__name__}({self.name}, type={self.type}, routing_key='{self.routing}'{body})"
 
-    def __hash__(self) -> int:
-        """Supports hash to store real objects in declarer."""
-        return sum(
-            (
-                hash(self.name),
-                hash(self.type),
-                hash(self.routing_key),
-                int(self.durable),
-                int(self.auto_delete),
-            ),
-        )
-
     @property
     def routing(self) -> str:
         """Return real routing_key of object."""

faststream/rabbit/schemas/queue.py

@@ -54,17 +54,6 @@ def __repr__(self) -> str:
 
         return f"{self.__class__.__name__}({self.name}, routing_key='{self.routing}'{body})"
 
-    def __hash__(self) -> int:
-        """Supports hash to store real objects in declarer."""
-        return sum(
-            (
-                hash(self.name),
-                int(self.durable),
-                int(self.exclusive),
-                int(self.auto_delete),
-            ),
-        )
-
     @property
     def routing(self) -> str:
         """Return real routing_key of object."""