From c1689bf02c03f3598a54dc972d8a128ecd4294ad Mon Sep 17 00:00:00 2001 From: yangzhenyu Date: Tue, 16 Jan 2018 20:21:56 +0800 Subject: [PATCH] Support client for delayed queues Implement blueprint delayed-queues Change-Id: Iabb56212535fa4d7a3f4444b285c4034b65352f6 --- zaqarclient/queues/v2/cli.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/zaqarclient/queues/v2/cli.py b/zaqarclient/queues/v2/cli.py index 6fcd2004..b2426f5a 100644 --- a/zaqarclient/queues/v2/cli.py +++ b/zaqarclient/queues/v2/cli.py @@ -208,6 +208,10 @@ class ListMessages(command.Lister): "--include-claimed", action="store_true", help="Whether to include claimed messages") + parser.add_argument( + "--include-delayed", + action="store_true", + help="Whether to include delayed messages") parser.add_argument( "--client-id", metavar="", @@ -234,6 +238,8 @@ class ListMessages(command.Lister): kwargs["echo"] = parsed_args.echo if parsed_args.include_claimed is not None: kwargs["include_claimed"] = parsed_args.include_claimed + if parsed_args.include_delayed is not None: + kwargs["include_delayed"] = parsed_args.include_delayed queue = client.queue(parsed_args.queue_name)