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

Signed-off-by: Jack Ding <[email protected]>
redhat-cne · Aug 21, 2024 · 3b5f656 · 3b5f656
1 parent d6f8679
commit 3b5f656
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, "")
 }