Shutdown FastStream app when STOMP broker becomes unavailable (but was available when app started)

[vrslev]

No description provided.

[vrslev]

Don't know how to test it, sadly :( Tried this:

diff --git a/packages/faststream-stomp/test_faststream_stomp/test_integration.py b/packages/faststream-stomp/test_faststream_stomp/test_integration.py
index e326fd1..d438595 100644
--- a/packages/faststream-stomp/test_faststream_stomp/test_integration.py
+++ b/packages/faststream-stomp/test_faststream_stomp/test_integration.py
@@ -225,3 +225,18 @@ async def test_broker_connect_twice(broker: faststream_stomp.StompBroker) -> Non
     app = AsgiFastStream(broker, on_startup=[broker.connect])
     async with LifespanManager(app):
         pass
+
+
+async def test_broker_connection_becomes_unavailable(
+    broker: faststream_stomp.StompBroker, monkeypatch: pytest.MonkeyPatch
+) -> None:
+    class CustomException(Exception): ...
+
+    monkeypatch.setattr("builtins.SystemExit", CustomException)
+    async with broker:
+        assert broker._connection
+        broker._connection._listen_task.get_coro().throw(
+            BaseExceptionGroup("", [stompman.FailedAllConnectAttemptsError(retry_attempts=0, issues=[])])
+        )
+        with pytest.raises(CustomException):
+            await asyncio.sleep(0)

Results in asyncio.exceptions.CancelledError