run-autopkgtest: Add persistent messages

This means the server should write them to disk as soon as possible, so they can be recovered if it crashes.
6 years ago · ff553758a6
parent c3fe5dc897
commit ff553758a6
1 changed files with 2 additions and 1 deletions
--- a/3
+++ b/3
@ -145,5 +145,6 @@ if __name__ == '__main__':
            for arch in args.architecture:
                queue = 'debci-%s%s-%s' % (context, args.series, arch)
                for pkg in args.package:
-                    ch.basic_publish(amqp.Message(pkg + params),
+                    ch.basic_publish(amqp.Message(pkg + params,
+                                                  delivery_mode=2),  # persistent
                                     routing_key=queue)