Claim release CLI support for v1

Change-Id: Ia79fbaacccb9014a0968e2c6d84c7c54694559df
This commit is contained in:
MD NADEEM 2015-12-23 16:48:31 +05:30 committed by MD NADEEM
parent cef4f9b696
commit e8c303956f
2 changed files with 26 additions and 0 deletions

View File

@ -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

View File

@ -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="<queue_name>",
help="Name of the claimed queue")
parser.add_argument(
"claim_id",
metavar="<claim_id>",
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()