diff --git a/gateway.py b/gateway.py
index 442e547..f60998a 100755
--- a/gateway.py
+++ b/gateway.py
@@ -26,7 +26,8 @@ else:
 _LOGGER.debug('Starting')
 
 mqtt = MqttClient(settings['mqtt'])
-WorkersManager().register_workers(settings['manager']).start(mqtt)
+manager = WorkersManager()
+manager.register_workers(settings['manager']).start(mqtt)
 
 running = True
 
diff --git a/workers_manager.py b/workers_manager.py
index 8ab700e..cc9a41b 100644
--- a/workers_manager.py
+++ b/workers_manager.py
@@ -65,8 +65,8 @@ class WorkersManager:
     return self
 
   def start(self, mqtt):
-    self._scheduler.start()
     mqtt.callbacks_subscription(self._mqtt_callbacks)
+    self._scheduler.start()
     self.update_all()
 
   def _queue_if_matching_payload(self, command, payload, expected_payload):