diff --git a/platypush/backend/kafka/__init__.py b/platypush/backend/kafka/__init__.py index c0fabbff..9ce04be0 100644 --- a/platypush/backend/kafka/__init__.py +++ b/platypush/backend/kafka/__init__.py @@ -41,6 +41,9 @@ class KafkaBackend(Backend): def run(self): 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: self._on_record(msg) diff --git a/platypush/backend/pushbullet/__init__.py b/platypush/backend/pushbullet/__init__.py index f42ee979..3df899db 100644 --- a/platypush/backend/pushbullet/__init__.py +++ b/platypush/backend/pushbullet/__init__.py @@ -83,6 +83,9 @@ class PushbulletBackend(Backend): def run(self): self._init_socket() + logging.info('Initialized Pushbullet backend - device_id: {}' + .format(self.device)) + self.ws.run_forever() # vim:sw=4:ts=4:et: