def subscribe()

in AWSIoTDeviceDefenderAgentSDK/agent.py [0:0]

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

    def subscribe(self, subscribe_to_topic, callback):
        """Subscribe to MQTT"""
        subscribe_future, packet_id = self.iot_client.subscribe(
            topic=subscribe_to_topic,
            qos=mqtt.QoS.AT_LEAST_ONCE,
            callback=callback)

        subscribe_result = subscribe_future.result()
        print("Subscribed to "+subscribe_to_topic+" with "+str(subscribe_result['qos']))
        return subscribe_result