}
return resp_data
except Exception as e:
- raise DmaapClientException('create apikey from dmaap failed: ' + e.message)
+ raise DmaapClientException('create apikey from dmaap failed: ' + str(e))
def get_apikey(self, apikey):
try:
ret = ret.json()
return ret
except Exception as e:
- raise DmaapClientException('get apikey from dmaap failed: ' + e.message)
+ raise DmaapClientException('get apikey from dmaap failed: ' + str(e))
def delete_apikey(self):
pass
self.scheduler.start()
except Exception as e:
logger.error('start sdc controller failed.')
- logger.error(e.message)
+ logger.error(str(e))
logger.error(traceback.format_exc())
def fetch_notification(self):
process_notification(notification_callback)
except Exception as e:
logger.error('fetch message from dmaap failed.')
- logger.error(e.message)
+ logger.error(str(e))
logger.error(traceback.format_exc())
logger.error('failed to send notification status, %s messages unsent', len(stuck))
except Exception as e:
logger.error('failed to send notification status.')
- logger.error(e.message)
+ logger.error(str(e))
logger.error(traceback.format_exc())
return status