def connect()

in GreengrassAwareConnection.py [0:0]

• 24 lines of code
• 4 McCabe index (conditional complexity)

    def connect(self):
        if self.isConnected():
            return

        self.client = AWSIoTMQTTClient(self.thingName)
        self.client.configureCredentials(self._getCA(), self.key, self.cert)

        for connectivityInfo in self.coreInfo.connectivityInfoList:
            currentHost = connectivityInfo.host
            currentPort = connectivityInfo.port
            self.logger.info("Trying to connect to core at %s:%d" % (currentHost, currentPort))
            self.client.configureEndpoint(currentHost, currentPort)
            try:
                self.client.configureAutoReconnectBackoffTime(1, 128, 20)
                self.client.configureOfflinePublishQueueing(self.offline_queue_depth)
                self.client.configureDrainingFrequency(50)
                self.client.configureMQTTOperationTimeout(10)

                self.client.onOnline = self.onOnline
                self.client.onOffline = self.onOffline

                self.client.connect()
                self.connected = True

                self.currentHost = currentHost
                self.currentPort = currentPort
                break
            except BaseException as e:
                self.logger.warn("Error in Connect: Type: %s" % str(type(e)))