From e8c303956faf30c549167063b8970e3efa0ad679 Mon Sep 17 00:00:00 2001 From: MD NADEEM Date: Wed, 23 Dec 2015 16:48:31 +0530 Subject: [PATCH] Claim release CLI support for v1 Change-Id: Ia79fbaacccb9014a0968e2c6d84c7c54694559df --- setup.cfg | 1 + zaqarclient/queues/v1/cli.py | 25 +++++++++++++++++++++++++ 2 files changed, 26 insertions(+) diff --git a/setup.cfg b/setup.cfg index e30a1c8b..7eab70ef 100644 --- a/setup.cfg +++ b/setup.cfg @@ -67,6 +67,7 @@ openstack.messaging.v1 = claim_create = zaqarclient.queues.v1.cli:CreateClaim claim_query = zaqarclient.queues.v1.cli:QueryClaim claim_renew = zaqarclient.queues.v1.cli:RenewClaim + claim_release = zaqarclient.queues.v1.cli:ReleaseClaim openstack.messaging.v2 = queue_list = zaqarclient.queues.v2.cli:ListQueues diff --git a/zaqarclient/queues/v1/cli.py b/zaqarclient/queues/v1/cli.py index 11228c32..6797d994 100644 --- a/zaqarclient/queues/v1/cli.py +++ b/zaqarclient/queues/v1/cli.py @@ -690,3 +690,28 @@ class RenewClaim(lister.Lister): return (columns, (utils.get_item_properties(s, keys) for s in data)) + + +class ReleaseClaim(command.Command): + """Delete a claim""" + + log = logging.getLogger(__name__ + ".ReleaseClaim") + + def get_parser(self, prog_name): + parser = super(ReleaseClaim, self).get_parser(prog_name) + parser.add_argument( + "queue_name", + metavar="", + help="Name of the claimed queue") + parser.add_argument( + "claim_id", + metavar="", + help="Claim ID to delete") + + return parser + + def take_action(self, parsed_args): + client = _get_client(self, parsed_args) + + queue = client.queue(parsed_args.queue_name, auto_create=False) + queue.claim(id=parsed_args.claim_id).delete()