diff --git a/cloud/shepherd/equinix/manager/server/main.go b/cloud/shepherd/equinix/manager/server/main.go
index e9b9289..2a293dc 100644
--- a/cloud/shepherd/equinix/manager/server/main.go
+++ b/cloud/shepherd/equinix/manager/server/main.go
@@ -24,6 +24,7 @@
 	SharedConfig      manager.SharedConfig
 	ProvisionerConfig manager.ProvisionerConfig
 	InitializerConfig manager.InitializerConfig
+	RecovererConfig   manager.RecovererConfig
 	WebugConfig       webug.Config
 	API               wrapngo.Opts
 }
@@ -46,6 +47,7 @@
 	c.SharedConfig.RegisterFlags("")
 	c.ProvisionerConfig.RegisterFlags()
 	c.InitializerConfig.RegisterFlags()
+	c.RecovererConfig.RegisterFlags()
 	c.WebugConfig.RegisterFlags()
 	c.API.RegisterFlags()
 }
@@ -87,6 +89,11 @@
 		klog.Exitf("%v", err)
 	}
 
+	recoverer, err := manager.NewRecoverer(api, c.RecovererConfig)
+	if err != nil {
+		klog.Exitf("%v", err)
+	}
+
 	conn, err := c.BMDB.Open(true)
 	if err != nil {
 		klog.Exitf("Failed to open BMDB connection: %v", err)
@@ -105,6 +112,12 @@
 		}
 	}()
 	go func() {
+		err = manager.RunControlLoop(ctx, conn, recoverer)
+		if err != nil {
+			klog.Exit(err)
+		}
+	}()
+	go func() {
 		if err := c.WebugConfig.Start(ctx, conn); err != nil && err != ctx.Err() {
 			klog.Exitf("Failed to start webug: %v", err)
 		}