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

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

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