Fix hashing and equality consistency in RabbitMQ schemas

Author: RinZ27

faststream/rabbit/schemas/exchange.py

@@ -44,6 +44,8 @@ def __eq__(self, value: object, /) -> bool:
             and self.routing_key == value.routing_key
             and self.durable == value.durable
             and self.auto_delete == value.auto_delete
+            and self.robust == value.robust
+            and self.arguments == value.arguments
         )
 
     def __hash__(self) -> int:
@@ -55,6 +57,8 @@ def __hash__(self) -> int:
                 self.routing_key,
                 self.durable,
                 self.auto_delete,
+                self.robust,
+                frozenset((self.arguments or {}).items()),
             ),
         )
 

faststream/rabbit/schemas/queue.py

@@ -63,6 +63,8 @@ def __eq__(self, value: object, /) -> bool:
             and self.durable == value.durable
             and self.exclusive == value.exclusive
             and self.auto_delete == value.auto_delete
+            and self.robust == value.robust
+            and self.arguments == value.arguments
         )
 
     def __hash__(self) -> int:
@@ -73,6 +75,8 @@ def __hash__(self) -> int:
                 self.durable,
                 self.exclusive,
                 self.auto_delete,
+                self.robust,
+                frozenset((self.arguments or {}).items()),
             ),
         )
 

tests/brokers/rabbit/specific/test_channels.py

@@ -12,7 +12,7 @@ async def test_subscriber_use_shared_channel() -> None:
     broker = RabbitBroker(logger=None)
 
     sub1 = broker.subscriber(uuid4().hex)
-    sub2 = broker.subscriber(uuid4().hex, channel=Channel())
+    sub2 = broker.subscriber(uuid4().hex, channel=Channel(prefetch_count=1))
 
     shared_channel = Channel()
     sub3 = broker.subscriber(uuid4().hex, channel=shared_channel)