We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6f21b5a commit a9f1acdCopy full SHA for a9f1acd
packages/faststream-stomp/faststream_stomp/subscriber.py
@@ -39,6 +39,8 @@ def __init__(
39
self.headers = headers
40
self.on_suppressed_exception = on_suppressed_exception
41
self.suppressed_exception_classes = suppressed_exception_classes
42
+ self._subscription: stompman.Subscription | None = None
43
+
44
super().__init__(
45
no_ack=self.ack == "auto",
46
no_reply=True,
@@ -93,7 +95,8 @@ async def start(self) -> None:
93
95
)
94
96
97
async def close(self) -> None:
- await self._subscription.unsubscribe()
98
+ if self._subscription:
99
+ await self._subscription.unsubscribe()
100
await super().close()
101
102
async def get_one(self, *, timeout: float = 5) -> None: ...
0 commit comments