+
+func (s *Subscription) UpdateRoute(act Action) error {
+ s.mutex.Lock()
+ defer s.mutex.Unlock()
+ return s.updateRouteImpl(act)
+}
+
+func (s *Subscription) Release() {
+ xapp.Logger.Info("Subscription: Releasing %s", s)
+ s.mutex.Lock()
+ defer s.mutex.Unlock()
+ s.registry.DelSubscription(s.Seq)
+ err := s.updateRouteImpl(DELETE)
+ if err != nil {
+ xapp.Logger.Error("Registry: Failed to del route. SubId: %d, RmrEndpoint: %s", s.Seq, s.RmrEndpoint)
+ }
+}