X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=catalog%2Fpub%2FDmaap_lib%2Fdmaap%2Fpublisher.py;h=3ffff542091b4ec109dd5bc18fde04e6edfe6169;hb=29020a784229dcdf3f0a5ad0558b5c58e00b904a;hp=23a23518b40f2efcc8ca4eb95bfa839973298dfa;hpb=4123780df595fd99883286e351a936349709ef68;p=modeling%2Fetsicatalog.git diff --git a/catalog/pub/Dmaap_lib/dmaap/publisher.py b/catalog/pub/Dmaap_lib/dmaap/publisher.py index 23a2351..3ffff54 100644 --- 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: - 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(): @@ -122,7 +122,7 @@ class BatchPublisherClient: return True except Exception as e: - logger.error(e.message) + logger.error(str(e)) return False def create_headers(self): @@ -163,7 +163,7 @@ class BatchPublisherClient: 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: