in GreengrassAwareConnection.py [0:0]
def __init__(self, host, rootCA, cert, key, thingName, stateChangeQueue = None, config={}):
self.logger = logging.getLogger("GreengrassAwareConnection")
self.logger.setLevel(logging.DEBUG)
streamHandler = logging.StreamHandler()
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
streamHandler.setFormatter(formatter)
self.logger.addHandler(streamHandler)
self.config = config
self.max_discovery_retries = self.config.get('MAX_DISCOVERY_RETRIES', 3)
self.group_ca_path = self.config.get('GROUP_CA_PATH', "./groupCA/")
self.offline_queue_depth = self.config.get('OFFLINE_QUEUE_DEPTH', 100)
self.host = host
self.rootCA = rootCA
self.cert = cert
self.key = key
self.thingName = thingName
self.stateChangeQueue = stateChangeQueue
self.backOffCore = ProgressiveBackOffCore()
self.discovered = False
self.discoverBroker()
self.connected = False
self.connect()
self.shadowConnected = False
self.connectShadow()
self.published_ids = []