openstack/python-zaqarclient
Code Issues Proposed changes

Updates API name

Browse Source 
Zaqar is a messaging service which provides support for different
messaging patterns and messaging related semantics.
This fix changes the old API name -queuing- to a more accurate name, -messaging-.

Change-Id: Icaf67607de962217819f8040abca7dd9b81aa1d4
This commit is contained in:
Victoria Martínez de la Cruz
2014-09-19 17:21:56 -03:00
parent 277779098c
commit d721b75039
4 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
setup.cfg
View File

@@ -44,7 +44,7 @@ zaqarclient.api =
queues.v1 = zaqarclient.queues.v1.api:V1 queues.v1 = zaqarclient.queues.v1.api:V1
queues.v1.1 = zaqarclient.queues.v1.api:V1_1 queues.v1.1 = zaqarclient.queues.v1.api:V1_1
openstack.queuing.v1 = openstack.messaging.v1 =
queue_list = zaqarclient.queues.v1.cli:ListQueues queue_list = zaqarclient.queues.v1.cli:ListQueues
queue_create = zaqarclient.queues.v1.cli:CreateQueue queue_create = zaqarclient.queues.v1.cli:CreateQueue
queue_delete = zaqarclient.queues.v1.cli:DeleteQueue queue_delete = zaqarclient.queues.v1.cli:DeleteQueue
@@ -54,7 +54,7 @@ openstack.queuing.v1 =
queue_stats = zaqarclient.queues.v1.cli:GetQueueStats queue_stats = zaqarclient.queues.v1.cli:GetQueueStats
openstack.cli.extension = openstack.cli.extension =
queuing = zaqarclient.queues.cli messaging = zaqarclient.queues.cli
[nosetests] [nosetests]
where=tests where=tests

2
zaqarclient/auth/keystone.py
View File

@@ -87,7 +87,7 @@ class KeystoneAuth(base.AuthBackend):
if not request.endpoint: if not request.endpoint:
extra = { extra = {
'service_type': self.conf.get('os_service_type', 'service_type': self.conf.get('os_service_type',
'queuing'), 'messaging'),
'endpoint_type': self.conf.get('os_endpoint_type', 'endpoint_type': self.conf.get('os_endpoint_type',
'publicURL'), 'publicURL'),
} }

2
zaqarclient/queues/cli.py
View File

@@ -21,7 +21,7 @@ LOG = logging.getLogger(__name__)
DEFAULT_QUEUES_API_VERSION = '1' DEFAULT_QUEUES_API_VERSION = '1'
API_VERSION_OPTION = 'os_queues_api_version' API_VERSION_OPTION = 'os_queues_api_version'
API_NAME = "queuing" API_NAME = "messaging"
API_VERSIONS = { API_VERSIONS = {
"1": "zaqarclient.queues.v1.client.Client", "1": "zaqarclient.queues.v1.client.Client",
} }

12
zaqarclient/queues/v1/cli.py
View File

@@ -63,7 +63,7 @@ class DeleteQueue(command.Command):
def take_action(self, parsed_args): def take_action(self, parsed_args):
self.log.debug("take_action(%s)" % parsed_args) self.log.debug("take_action(%s)" % parsed_args)
client = self.app.client_manager.queuing client = self.app.client_manager.messaging
queue_name = parsed_args.queue_name queue_name = parsed_args.queue_name
@@ -91,7 +91,7 @@ class ListQueues(lister.Lister):
def take_action(self, parsed_args): def take_action(self, parsed_args):
self.log.debug("take_action(%s)" % parsed_args) self.log.debug("take_action(%s)" % parsed_args)
client = self.app.client_manager.queuing client = self.app.client_manager.messaging
kwargs = {} kwargs = {}
if parsed_args.marker is not None: if parsed_args.marker is not None:
@@ -122,7 +122,7 @@ class CheckQueueExistence(show.ShowOne):
def take_action(self, parsed_args): def take_action(self, parsed_args):
self.log.debug("take_action(%s)" % parsed_args) self.log.debug("take_action(%s)" % parsed_args)
client = self.app.client_manager.queuing client = self.app.client_manager.messaging
queue_name = parsed_args.queue_name queue_name = parsed_args.queue_name
queue = client.queue(queue_name, auto_create=False) queue = client.queue(queue_name, auto_create=False)
@@ -152,7 +152,7 @@ class SetQueueMetadata(command.Command):
def take_action(self, parsed_args): def take_action(self, parsed_args):
self.log.debug("take_action(%s)" % parsed_args) self.log.debug("take_action(%s)" % parsed_args)
client = self.app.client_manager.queuing client = self.app.client_manager.messaging
queue_name = parsed_args.queue_name queue_name = parsed_args.queue_name
queue_metadata = parsed_args.queue_metadata queue_metadata = parsed_args.queue_metadata
@@ -187,7 +187,7 @@ class GetQueueMetadata(show.ShowOne):
def take_action(self, parsed_args): def take_action(self, parsed_args):
self.log.debug("take_action(%s)" % parsed_args) self.log.debug("take_action(%s)" % parsed_args)
client = self.app.client_manager.queuing client = self.app.client_manager.messaging
queue_name = parsed_args.queue_name queue_name = parsed_args.queue_name
queue = client.queue(queue_name, auto_create=False) queue = client.queue(queue_name, auto_create=False)
@@ -216,7 +216,7 @@ class GetQueueStats(show.ShowOne):
def take_action(self, parsed_args): def take_action(self, parsed_args):
self.log.debug("take_action(%s)" % parsed_args) self.log.debug("take_action(%s)" % parsed_args)
client = self.app.client_manager.queuing client = self.app.client_manager.messaging
queue_name = parsed_args.queue_name queue_name = parsed_args.queue_name
queue = client.queue(queue_name, auto_create=False) queue = client.queue(queue_name, auto_create=False)