Psion-fanatic/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Use the Redis backend to dispatch messages to the core bus if available

Browse source
This commit is contained in:
Fabio Manganiello 2018-06-12 09:20:17 +02:00
parent 7ab85b4cfa
commit 8c208c0028
1 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
platypush/backend/mqtt.py
View file

@ -5,6 +5,7 @@ import paho.mqtt.publish as publisher
from platypush.backend import Backend from platypush.backend import Backend
from platypush.message import Message from platypush.message import Message
from platypush.context import get_backend
class MqttBackend(Backend): class MqttBackend(Backend):
@ -26,6 +27,11 @@ class MqttBackend(Backend):
self.port = port self.port = port
self.topic = '{}/{}'.format(topic, self.device_id) self.topic = '{}/{}'.format(topic, self.device_id)
try:
self.redis = get_backend('redis')
except:
self.redis = None
def send_message(self, msg): def send_message(self, msg):
publisher.single(self.topic, str(msg), hostname=self.host, port=self.port) publisher.single(self.topic, str(msg), hostname=self.host, port=self.port)
@ -43,7 +49,11 @@ class MqttBackend(Backend):
pass pass
self.logger.info('Received message on the MQTT backend: {}'.format(msg)) self.logger.info('Received message on the MQTT backend: {}'.format(msg))
self.bus.post(msg)
if self.redis:
self.redis.send_message(msg)
else:
self.bus.post(msg)
super().run() super().run()
client = mqtt.Client() client = mqtt.Client()