def _setup_notification_listener(self, topic_name, url):
        """Setup notification listener for a service."""

        self.notify_listener = rpc.DfaNotifcationListener(
            topic_name, url, rpc.DfaNotificationEndpoints(self))