From 6d6ad5b0f546eb2861445cf7d8684ffe611ba80c Mon Sep 17 00:00:00 2001 From: Joe Keen Date: Wed, 6 Apr 2016 16:01:18 -0600 Subject: [PATCH] Retry engine trys to write bad data to Kafka Previous retry fix did not actually fix the problem. Change-Id: I2aa728d86a9cd21022d681149fae8aeebf08be24 --- monasca_notification/retry_engine.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/monasca_notification/retry_engine.py b/monasca_notification/retry_engine.py index 49f9ed2..968f423 100644 --- a/monasca_notification/retry_engine.py +++ b/monasca_notification/retry_engine.py @@ -78,7 +78,8 @@ class RetryEngine(object): sent, failed = self._notifier.send([notification]) if sent: - self._producer.publish(self._topics['notification_topic'], [sent.to_json()]) + self._producer.publish(self._topics['notification_topic'], + [notification.to_json()]) if failed: notification.retry_count += 1