openstack/ceilometer
Code Issues Proposed changes

Merge "Allow requeues in when there is a failure in EventsNotificationEndpoint"

Browse Source
This commit is contained in:
Zuul 2018-03-26 14:08:00 +00:00 committed by Gerrit Code Review
commit 3341095645
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ceilometer/notification.py
View File

@ -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
)
@ -238,7 +238,7 @@ class NotificationService(cotyledon.Service):
self.kill_listeners([self.pipeline_listener])
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