def init_mqtt_publisher()

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

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

    def init_mqtt_publisher(self):
        '''
            Initialise publisher to requested IoT Core MQTT topics.
        '''

        try:
            log.info('Initialising MQTT Publisher.')
            self.mqtt_request = PublishToIoTCoreRequest()
            self.mqtt_request.qos = self.mqtt_qos

        except Exception as err: # pragma: no cover
            log.exception('EXCEPTION: Exception Initialising MQTT Publisher. ERROR MESSAGE: {}'.format(err))