openstack
/
monasca-notification
Code Issues Proposed changes

Retry engine trys to write bad data to Kafka 

Previous retry fix did not actually fix the problem.

Change-Id: I2aa728d86a9cd21022d681149fae8aeebf08be24
This commit is contained in:
Joe Keen 2016-04-06 16:01:18 -06:00 committed by Michael James Hoppal
parent b6b3b1a419
commit 6d6ad5b0f5
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
monasca_notification/retry_engine.py
View File

@ -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