diff --git a/confluent_server/confluent/discovery/core.py b/confluent_server/confluent/discovery/core.py
index a7cef05e..302dc47e 100644
--- a/confluent_server/confluent/discovery/core.py
+++ b/confluent_server/confluent/discovery/core.py
@@ -1446,13 +1446,14 @@ def _periodic_recheck(configmanager):
 def rescan():
     _map_unique_ids()
     global scanner
+    mycfm = cfm.ConfigManager(None)
+    myname = collective.get_myname()
     if scanner:
         return
     else:
         scanner = eventlet.spawn(blocking_scan)
     for remagent in get_subscriptions():
-        affluent.
-
+        affluent.renotify_my(remagent, mycfm, myname)
 
 
 def blocking_scan():
diff --git a/confluent_server/confluent/plugins/hardwaremanagement/affluent.py b/confluent_server/confluent/plugins/hardwaremanagement/affluent.py
index 3de25907..71cecea9 100644
--- a/confluent_server/confluent/plugins/hardwaremanagement/affluent.py
+++ b/confluent_server/confluent/plugins/hardwaremanagement/affluent.py
@@ -58,7 +58,8 @@ def renotify_me(node, configmanager, myname):
     creds = configmanager.get_node_attributes(
         node, ['secret.hardwaremanagementuser', 'secret.hardwaremanagementpassword'], decrypt=True)
     wc = WebClient(node, configmanager, creds)
-    wc.wc.grab_json_response('/affluent/cert_authorities/{0}'.format(myname), cacert)
+    res, status = wc.wc.grab_json_response_with_status('/affluent/systems/renotify', {'subscriber': myname})
+
 
 def subscribe_discovery(node, configmanager, myname):
     creds = configmanager.get_node_attributes(