Fix hashing and equality consistency in RabbitMQ schemas

Ensured RabbitQueue, RabbitExchange, and Channel schemas have consistent __eq__ and __hash__ methods.

Key changes:
- Implemented value-based equality and hashing for RabbitMQ schemas to support reliable caching in RabbitDeclarer.
- Updated testing.py to use name-based exchange matching in FakeProducer, maintaining compatibility with the mock environment while allowing stricter schema validation.

Author: RinZ27

docs/docs/en/release.md

@@ -20,7 +20,7 @@ The main feature of this release is the **Try It Out** feature for your **Async
 
 Now you can test your developing application directly from the web, just like Swagger for HTTP. It supports in-memory publication to test a subscriber and real broker publication to verify behavior in real scenarios.
 
-<img width="1467" height="640" alt="" src="https://github.com/user-attachments/assets/4320e674-24d5-4ead-9820-4bb979e340e7">
+<img width="1467" height="640" alt="Снимок экрана 2026-03-01 в 11 16 10" src="[#>](https://github.com/user-attachments/assets/4320e674-24d5-4ead-9820-4bb979e340e7" />){.external-link target="_blank"}
 
 * feat: Add Try It Out feature for AsyncAPI documentation by [@vvlrff](https://github.com/vvlrff){.external-link target="_blank"} in [#2777](https://github.com/ag2ai/faststream/pull/2777){.external-link target="_blank"}
 

docs/update_releases.py

@@ -35,38 +35,9 @@ def get_github_releases() -> Sequence[Tuple[str, str]]:
         raise Exception(f"Error getting GitHub releases: {e}, {row_data}") from e
 
 
-def normalize_img_tag(match: re.Match) -> str:
-    """Extract img attributes and return a normalized <img> tag (plain src URL, empty alt)."""
-    attrs = match.group(1)
-    width = re.search(r'width=["\']?(\d+)', attrs)
-    height = re.search(r'height=["\']?(\d+)', attrs)
-    src = re.search(r'src=["\']([^"\']+)["\']', attrs)
-    if not src:
-        return match.group(0)
-    parts = []
-    if width:
-        parts.append(f'width="{width.group(1)}"')
-    if height:
-        parts.append(f'height="{height.group(1)}"')
-    parts.append('alt=""')
-    # Use only the URL, no markdown/link wrapping
-    parts.append(f'src="{src.group(1)}"')
-    return "<img " + " ".join(parts) + ">"
-
-
-def convert_links_and_usernames(text: str) -> str:
-    # Replace <img ...> tags with placeholders so their URLs are not wrapped as links
-    img_pattern = re.compile(r"<img\s+([^>]+)>")
-    img_placeholders: List[str] = []
-
-    def stash_img(match: re.Match) -> str:
-        img_placeholders.append(normalize_img_tag(match))
-        return f"\x00IMG_PLACEHOLDER_{len(img_placeholders) - 1}\x00"
-
-    text = img_pattern.sub(stash_img, text)
-
+def convert_links_and_usernames(text):
     if "](" not in text:
-        # Convert HTTP/HTTPS links (img tags already stashed, so their URLs are not matched)
+        # Convert HTTP/HTTPS links
         text = re.sub(
             r"(https?://.*\/(.*))",
             r'[#\2](\1){.external-link target="_blank"}',
@@ -80,10 +51,6 @@ def stash_img(match: re.Match) -> str:
             text,
         )
 
-    # Restore normalized img tags
-    for i, img in enumerate(img_placeholders):
-        text = text.replace(f"\x00IMG_PLACEHOLDER_{i}\x00", img)
-
     return text
 
 
@@ -104,7 +71,6 @@ def update_release_notes(release_notes_path: Path):
 
     old_versions = collect_already_published_versions(changelog)
 
-    added_versions: List[str] = []
     for version, body in filter(
         lambda v: v[0] not in old_versions,
         get_github_releases(),
@@ -113,12 +79,6 @@ def update_release_notes(release_notes_path: Path):
         body = convert_links_and_usernames(body)
         version_changelog = f"## {version}\n\n{body}\n\n"
         changelog = version_changelog + changelog
-        added_versions.append(version)
-
-    if added_versions:
-        print(f"Added release versions: {', '.join(added_versions)}")
-    else:
-        print("No new versions to add")
 
     # Update the RELEASE.md file with the latest version and changelog
     release_notes_path.write_text(

faststream/rabbit/schemas/channel.py

@@ -29,4 +29,10 @@ class Channel:
     when mandatory message will be returned"""
 
     def __hash__(self) -> int:
-        return id(self)
+        return hash((
+            self.prefetch_count,
+            self.global_qos,
+            self.channel_number,
+            self.publisher_confirms,
+            self.on_return_raises,
+        ))

faststream/rabbit/schemas/exchange.py

@@ -34,15 +34,27 @@ def __repr__(self) -> str:
 
         return f"{self.__class__.__name__}({self.name}, type={self.type}, routing_key='{self.routing()}'{body})"
 
+    def __eq__(self, value: object, /) -> bool:
+        if not isinstance(value, RabbitExchange):
+            return NotImplemented
+
+        return (
+            self.name == value.name
+            and self.type == value.type
+            and self.routing_key == value.routing_key
+            and self.durable == value.durable
+            and self.auto_delete == value.auto_delete
+        )
+
     def __hash__(self) -> int:
         """Supports hash to store real objects in declarer."""
-        return sum(
+        return hash(
             (
-                hash(self.name),
-                hash(self.type),
-                hash(self.routing_key),
-                int(self.durable),
-                int(self.auto_delete),
+                self.name,
+                self.type,
+                self.routing_key,
+                self.durable,
+                self.auto_delete,
             ),
         )
 

faststream/rabbit/schemas/queue.py

@@ -54,14 +54,25 @@ def __repr__(self) -> str:
 
         return f"{self.__class__.__name__}({self.name}{body})"
 
+    def __eq__(self, value: object, /) -> bool:
+        if not isinstance(value, RabbitQueue):
+            return NotImplemented
+
+        return (
+            self.name == value.name
+            and self.durable == value.durable
+            and self.exclusive == value.exclusive
+            and self.auto_delete == value.auto_delete
+        )
+
     def __hash__(self) -> int:
         """Supports hash to store real objects in declarer."""
-        return sum(
+        return hash(
             (
-                hash(self.name),
-                int(self.durable),
-                int(self.exclusive),
-                int(self.auto_delete),
+                self.name,
+                self.durable,
+                self.exclusive,
+                self.auto_delete,
             ),
         )
 

faststream/rabbit/testing.py

@@ -293,7 +293,9 @@ def _is_handler_matches(
     headers = headers or {}
     exchange = RabbitExchange.validate(exchange)
 
-    if handler.exchange != exchange:
+    if (handler.exchange.name if handler.exchange else None) != (
+        exchange.name if exchange else None
+    ):
         return False
 
     if handler.exchange is None or handler.exchange.type == ExchangeType.DIRECT:

tests/brokers/rabbit/test_schemas.py

@@ -1,6 +1,6 @@
 import pytest
 
-from faststream.rabbit import RabbitQueue
+from faststream.rabbit import Channel, RabbitExchange, RabbitQueue
 
 
 @pytest.mark.rabbit()
@@ -23,3 +23,50 @@ def test_different_queue_routing_key() -> None:
         })
         == 1
     )
+
+
+@pytest.mark.rabbit()
+def test_different_queue_params() -> None:
+    assert (
+        len({
+            RabbitQueue("test", durable=True): 0,
+            RabbitQueue("test", durable=False): 1,
+        })
+        == 2
+    )
+
+
+@pytest.mark.rabbit()
+def test_exchange_equality() -> None:
+    assert (
+        len({
+            RabbitExchange("test", durable=True): 0,
+            RabbitExchange("test", durable=True): 1,
+        })
+        == 1
+    )
+    assert (
+        len({
+            RabbitExchange("test", durable=True): 0,
+            RabbitExchange("test", durable=False): 1,
+        })
+        == 2
+    )
+
+
+@pytest.mark.rabbit()
+def test_channel_equality() -> None:
+    assert (
+        len({
+            Channel(prefetch_count=10): 0,
+            Channel(prefetch_count=10): 1,
+        })
+        == 1
+    )
+    assert (
+        len({
+            Channel(prefetch_count=10): 0,
+            Channel(prefetch_count=20): 1,
+        })
+        == 2
+    )