Code Review
/
modeling
/
etsicatalog.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix the Exception with e.message problem
[modeling/etsicatalog.git]
/
catalog
/
pub
/
Dmaap_lib
/
dmaap
/
publisher.py
diff --git
a/catalog/pub/Dmaap_lib/dmaap/publisher.py
b/catalog/pub/Dmaap_lib/dmaap/publisher.py
index
23a2351
..
3ffff54
100644
(file)
--- a/
catalog/pub/Dmaap_lib/dmaap/publisher.py
+++ b/
catalog/pub/Dmaap_lib/dmaap/publisher.py
@@
-60,7
+60,7
@@
class BatchPublisherClient:
self.pending.append(message)
return len(self.pending)
except Exception as e:
self.pending.append(message)
return len(self.pending)
except Exception as e:
- raise DmaapClientException("append message failed: " +
e.message
)
+ raise DmaapClientException("append message failed: " +
str(e)
)
def send_message(self, force):
if force or self.should_send_now():
def send_message(self, force):
if force or self.should_send_now():
@@
-122,7
+122,7
@@
class BatchPublisherClient:
return True
except Exception as e:
return True
except Exception as e:
- logger.error(
e.message
)
+ logger.error(
str(e)
)
return False
def create_headers(self):
return False
def create_headers(self):
@@
-163,7
+163,7
@@
class BatchPublisherClient:
time.sleep(0.25)
return self.pending
except Exception as e:
time.sleep(0.25)
return self.pending
except Exception as e:
- raise DmaapClientException("send message failed: " +
e.message
)
+ raise DmaapClientException("send message failed: " +
str(e)
)
class Message:
class Message: