added mqtt transport tostation

r-map · Jan 6, 2016 · d997084 · d997084
1 parent 21fbeb5
commit d997084
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/python/rmap/rmapstation.py b/python/rmap/rmapstation.py
@@ -1028,6 +1028,13 @@ def starttransport(self):
             print "start serial"
             self.transport=jsonrpc.TransportSERIAL(port=self.serial_device,baudrate=self.serial_baudrate, logfunc=self.log)
 
+        if self.transport_name == "mqtt":
+            print "start mqtt"
+            self.transport=jsonrpc.TransportMQTT(user=self.mqtt_user,
+                                                 password=self.mqtt_password,
+                                                 host=self.mqtt_host,
+                                                 logfunc=self.log)
+
         if self.transport is None:
             raise Exception("start transport",1)