def publishMessageOnTopic()

in GreengrassAwareConnection.py [0:0]

• 18 lines of code
• 7 McCabe index (conditional complexity)

    def publishMessageOnTopic(self, message, topic, qos=0):
        if not self.isConnected():
            raise ConnectionError()

        result = MQTT_ERR_SUCCESS
        did_publish = False
        try:
            result = self.client.publishAsync(topic, message, qos, self.pubAck)
            did_publish = True

            # may be QUEUED or has ID
            self.published_ids.append(int(result))

        except ValueError as e:
            # print(f"message queued - {result}")
            pass
        except publishError as e:
            print(f"Publish Error: {e.message}")
        except publishQueueFullException as e:
            print(f"Publish Full Exception: {e.message}")
        except Exception as e:
            print(f"Another Exception: {type(e)}")

        return did_publish