diff --git a/controller/northbound/server/submanagement.go b/controller/northbound/server/submanagement.go index a59a4fef0c7b66700ba92ba15e850634d2a4c5c3..bdc67e4e13f8ce3327ebd3a812f0af54fc6e4131 100644 --- a/controller/northbound/server/submanagement.go +++ b/controller/northbound/server/submanagement.go @@ -23,11 +23,12 @@ func NewSubManagementServer(networkElementWatchter *nucleus.NetworkElementWatche // ResetAllSubscriptions stops all running subscriptions and restarts them the same way they ran before. func (s *SubManagementServer) ResetAllSubscriptions(ctx context.Context, request *subpb.ResetAllSubscriptionsRequest) (*subpb.ResetAllSubscriptionsResponse, error) { + subscriptions := s.networkElementWatchter.GetAllSubscriptionInformations() + s.networkElementWatchter.StopAndRemoveAllNetworkElementSubscriptions() - //TODO: first get all relevant sub information and then provide the options here. // Requires some rework of current way how paths/options are provided to the watcher. - s.networkElementWatchter.SubscribeToNetworkElements(nil) + s.networkElementWatchter.SubscribeToNetworkElements(subscriptions[0].Opts) return &subpb.ResetAllSubscriptionsResponse{ Timestamp: time.Now().UnixNano(),