code: def _setup_notification_listener(self, topic_name, url):
          
  
          self.notify_listener = rpc.DfaNotifcationListener(
              topic_name, url, rpc.DfaNotificationEndpoints(self))
docs: Setup notification listener for a service.