diff --git a/cbpi/__init__.py b/cbpi/__init__.py
index 8ca05d8..0616906 100644
--- a/cbpi/__init__.py
+++ b/cbpi/__init__.py
@@ -1,2 +1,2 @@
-__version__ = "4.0.1.1"
+__version__ = "4.0.1.2d1"
 
diff --git a/cbpi/api/sensor.py b/cbpi/api/sensor.py
index 76182d5..4ed9777 100644
--- a/cbpi/api/sensor.py
+++ b/cbpi/api/sensor.py
@@ -32,10 +32,11 @@ class CBPiSensor(CBPiBase, metaclass=ABCMeta):
     def get_unit(self):
         pass
 
-    def push_update(self, value):
+    def push_update(self, value, mqtt = True):
         try:
             self.cbpi.ws.send(dict(topic="sensorstate", id=self.id, value=value))
-            self.cbpi.push_update("cbpi/sensordata/{}".format(self.id), dict(id=self.id, value=value), retain=True)
+            if mqtt:
+                self.cbpi.push_update("cbpi/sensordata/{}".format(self.id), dict(id=self.id, value=value), retain=True)
 #            self.cbpi.push_update("cbpi/sensor/{}/udpate".format(self.id), dict(id=self.id, value=value), retain=True)
         except:
             logging.error("Faild to push sensor update")