v2 clean up subscriptions: cleanup in memory store (redhat-cne#78)

Signed-off-by: Jack Ding <[email protected]>
jzding · Aug 29, 2024 · bbadde1 · bbadde1
1 parent dba0ac0
commit bbadde1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/v2/routes.go b/v2/routes.go
@@ -365,6 +365,11 @@ func (s *Server) deleteAllSubscriptions(w http.ResponseWriter, _ *http.Request)
 		respondWithError(w, err.Error())
 		return
 	}
+	// empty the store in memory
+	if err = s.pubSubAPI.DeleteAllSubscriptions(); err != nil {
+		respondWithError(w, err.Error())
+		return
+	}
 
 	respondWithStatusCode(w, http.StatusNoContent, "")
 }