MySmartHome/bt-mqtt-gateway
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Small mqtt refactor

Browse Source
This commit is contained in:
zewelor
2018-04-02 21:06:00 +02:00
parent 06cfca60c1
commit 6f64df929a
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mqtt.py
+1 -1
View File
@@ -5,7 +5,7 @@ import paho.mqtt.client as mqtt
class MqttClient: class MqttClient:
def __init__(self, config): def __init__(self, config):
self._config = config self._config = config
self._mqttc = mqtt.Client() self._mqttc = mqtt.Client(client_id='bt-mqtt-gateway', clean_session=False)
def publish(self, messages): def publish(self, messages):
if messages is None: if messages is None:
workers_manager.py
+1
View File
@@ -98,4 +98,5 @@ class WorkersManager:
pip.main(['install', '-q', package]) pip.main(['install', '-q', package])
def _on_command_wrapper(self, worker_obj, client, _, c): def _on_command_wrapper(self, worker_obj, client, _, c):
_LOGGER.debug("on command wrapper for with %s: %s", c.topic, c.payload)
self._queue_command(self.Command(worker_obj.on_command, [c.topic, c.payload])) self._queue_command(self.Command(worker_obj.on_command, [c.topic, c.payload]))