Implement optional message persistence on callback events

2026-02-16 02:30:01 -03:30 · 2017-02-08 11:11:14 -05:00
parent 48e75b3e19
commit 4ed054f568
2 changed files with 2 additions and 0 deletions
--- a/awx/main/queue.py
+++ b/awx/main/queue.py
@@ -43,6 +43,7 @@ class CallbackQueueDispatcher(object):
                                 compression='bzip2',
                                 exchange=self.exchange,
                                 declare=[self.exchange],
+                                 delivery_mode="persistent" if settings.PERSISTENT_CALLBACK_MESSAGES else "transient",
                                 routing_key=self.connection_queue)
                return
            except Exception, e: