diff --git a/AutomForArduino.cpp b/AutomForArduino.cpp
index a56f398..31e6304 100644
--- a/AutomForArduino.cpp
+++ b/AutomForArduino.cpp
@@ -118,7 +118,11 @@ public:
   }
 };
 
+callback cb;
+
 void mqtt_open(mqtt::async_client* client) {
+
+  client->set_callback(cb);
   mqtt::connect_options connOpts;
   connOpts.set_clean_session(true);
   connOpts.set_user_name("admin");
diff --git a/main.cpp b/main.cpp
index 11974e7..3d5aee6 100644
--- a/main.cpp
+++ b/main.cpp
@@ -4,12 +4,9 @@
 #undef timeout
 #include "mqtt/async_client.h"
 
-
-
 int main()
 {
-  callback cb;
-  client.set_callback(cb);
+
 
   mqtt_open(&client);