diff options
| author | Luis Pigueiras <luis.pigueiras@cern.ch> | 2017-09-29 11:04:53 +0200 |
|---|---|---|
| committer | gord chung <gord@live.ca> | 2017-11-28 14:42:30 -0500 |
| commit | 35d501c4d85734a4e5741cc79cae51578e5ea379 (patch) | |
| tree | c55a9ddaee3f1d984e0df383bbc2df82922f8f55 /ceilometer/notification.py | |
| parent | 6f946db775bd7e157b3380bc87fb36bbe2955723 (diff) | |
| download | ceilometer-35d501c4d85734a4e5741cc79cae51578e5ea379.tar.gz | |
Allow requeues in when there is a failure in EventsNotificationEndpoint
When `ack_on_event_error` is set to False, it ack's the notification
anyway. The reason behind this is the configuration of the batch
notification listener which doesn't allow requeues
Change-Id: I5511272c4dc2d5759cab8b9e695bbd9ed6a1bf6a
Closes-Bug: #1720329
Diffstat (limited to 'ceilometer/notification.py')
| -rw-r--r-- | ceilometer/notification.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ceilometer/notification.py b/ceilometer/notification.py index c6c71f6b..ff92b527 100644 --- a/ceilometer/notification.py +++ b/ceilometer/notification.py @@ -206,7 +206,7 @@ class NotificationService(cotyledon.Service): # NOTE(gordc): ignore batching as we want pull # to maintain sequencing as much as possible. listener = messaging.get_batch_notification_listener( - transport, targets, endpoints) + transport, targets, endpoints, allow_requeue=True) listener.start( override_pool_size=self.conf.max_parallel_requests ) @@ -239,7 +239,7 @@ class NotificationService(cotyledon.Service): self.pipeline_listener.wait() self.pipeline_listener = messaging.get_batch_notification_listener( - self.transport, targets, endpoints, + self.transport, targets, endpoints, allow_requeue=True, batch_size=self.conf.notification.batch_size, batch_timeout=self.conf.notification.batch_timeout) # NOTE(gordc): set single thread to process data sequentially |