From f51bfdb666c091908317b86d1ea52fc581e2ed47 Mon Sep 17 00:00:00 2001 From: Grant Limberg Date: Mon, 8 Sep 2025 10:25:32 -0700 Subject: [PATCH] delete pubsub subscription on shutdown --- nonfree/controller/PubSubListener.cpp | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/nonfree/controller/PubSubListener.cpp b/nonfree/controller/PubSubListener.cpp index 26f5b27c0..514a4522a 100644 --- a/nonfree/controller/PubSubListener.cpp +++ b/nonfree/controller/PubSubListener.cpp @@ -73,6 +73,11 @@ PubSubListener::~PubSubListener() if (_subscriberThread.joinable()) { _subscriberThread.join(); } + + auto status = _adminClient.DeleteSubscription(_subscription.FullName()); + if (! status.ok()) { + fprintf(stderr, "Failed to delete subscription: %s\n", status.message().c_str()); + } } void PubSubListener::subscribe()