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()