diff --git a/src/mqtt.js b/src/mqtt.js
index 1809096..3223ae8 100644
--- a/src/mqtt.js
+++ b/src/mqtt.js
@@ -30,7 +30,6 @@ export default function connectMqtt(url: string, store: Store<*,*>) {
     store.dispatch({ type: null });
   });
   client.on("reconnect", () => {
-    client.end();
     store.dispatch({ type: null });
   });
 }