openstack
/
python-zaqarclient
Code Issues Proposed changes

Support client for delayed queues 

Implement blueprint delayed-queues
Change-Id: Iabb56212535fa4d7a3f4444b285c4034b65352f6
This commit is contained in:
yangzhenyu 2018-01-16 20:21:56 +08:00
parent 927d29d5f7
commit c1689bf02c
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
zaqarclient/queues/v2/cli.py
View File

@ -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="<client_id>",
@ -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)