diff --git a/vmware_nsx/nsxlib/v3/cluster.py b/vmware_nsx/nsxlib/v3/cluster.py
index 088cfcb085..33d6560bcd 100644
--- a/vmware_nsx/nsxlib/v3/cluster.py
+++ b/vmware_nsx/nsxlib/v3/cluster.py
@@ -258,7 +258,7 @@ class ClusteredAPI(object):
         # reinitialize upon fork for api workers to ensure each
         # process has its own keepalive loops + state
         registry.subscribe(
-                _init_cluster, resources.PROCESS, events.AFTER_CREATE)
+                _init_cluster, resources.PROCESS, events.AFTER_INIT)
 
     def _init_endpoints(self, providers,
                         min_conns_per_pool, max_conns_per_pool):
diff --git a/vmware_nsx/plugins/nsx_v/plugin.py b/vmware_nsx/plugins/nsx_v/plugin.py
index 5898f28b42..8193e4e3e2 100644
--- a/vmware_nsx/plugins/nsx_v/plugin.py
+++ b/vmware_nsx/plugins/nsx_v/plugin.py
@@ -172,7 +172,7 @@ class NsxVPluginV2(addr_pair_db.AllowedAddressPairsMixin,
         self.init_is_complete = False
         registry.subscribe(self.init_complete,
                            resources.PROCESS,
-                           events.AFTER_CREATE)
+                           events.AFTER_INIT)
         self.metadata_proxy_handler = None
         config.validate_nsxv_config_options()
         neutron_extensions.append_api_extensions_path(