revil-O/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Consistent logging info

Browse source
This commit is contained in:
Fabio Manganiello 2017-12-12 19:26:23 +01:00
parent 7a58add0ad
commit 4b0706380e
2 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
platypush/backend/kafka/__init__.py
View file

@ -41,6 +41,9 @@ class KafkaBackend(Backend):
def run(self): def run(self):
self.consumer = KafkaConsumer(self.topic, bootstrap_servers=self.server) self.consumer = KafkaConsumer(self.topic, bootstrap_servers=self.server)
logging.info('Initialized kafka backend - server: {}, topic: {}'
.format(self.server, self.topic))
for msg in self.consumer: for msg in self.consumer:
self._on_record(msg) self._on_record(msg)

3
platypush/backend/pushbullet/__init__.py
View file

@ -83,6 +83,9 @@ class PushbulletBackend(Backend):
def run(self): def run(self):
self._init_socket() self._init_socket()
logging.info('Initialized Pushbullet backend - device_id: {}'
.format(self.device))
self.ws.run_forever() self.ws.run_forever()
# vim:sw=4:ts=4:et: # vim:sw=4:ts=4:et: