def on_stream_event()

in src/pubsub/mqtt_pubsub.py [0:0]

• 8 lines of code
• 2 McCabe index (conditional complexity)

        def on_stream_event(self, event: IoTCoreMessage) -> None:
            try:
                
                log.debug('MQTT MESSAGE RECEIVED: {}'.format(event))

                topic = event.message.topic_name    
                message = str(event.message.payload, "utf-8")
                
                self.executor.submit(self.message_callback, topic, message)

            except Exception as err: # pragma: no cover
                log.exception('EXCEPTION: Exception Raised from IoT Core on MQTT Subscriber. ERROR MESSAGE: {} - STREAM EVENT: {}'.format(err, event))