Updates API name
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:
parent
277779098c
commit
d721b75039
@ -44,7 +44,7 @@ zaqarclient.api =
|
||||
queues.v1 = zaqarclient.queues.v1.api:V1
|
||||
queues.v1.1 = zaqarclient.queues.v1.api:V1_1
|
||||
|
||||
openstack.queuing.v1 =
|
||||
openstack.messaging.v1 =
|
||||
queue_list = zaqarclient.queues.v1.cli:ListQueues
|
||||
queue_create = zaqarclient.queues.v1.cli:CreateQueue
|
||||
queue_delete = zaqarclient.queues.v1.cli:DeleteQueue
|
||||
@ -54,7 +54,7 @@ openstack.queuing.v1 =
|
||||
queue_stats = zaqarclient.queues.v1.cli:GetQueueStats
|
||||
|
||||
openstack.cli.extension =
|
||||
queuing = zaqarclient.queues.cli
|
||||
messaging = zaqarclient.queues.cli
|
||||
|
||||
[nosetests]
|
||||
where=tests
|
||||
|
@ -87,7 +87,7 @@ class KeystoneAuth(base.AuthBackend):
|
||||
if not request.endpoint:
|
||||
extra = {
|
||||
'service_type': self.conf.get('os_service_type',
|
||||
'queuing'),
|
||||
'messaging'),
|
||||
'endpoint_type': self.conf.get('os_endpoint_type',
|
||||
'publicURL'),
|
||||
}
|
||||
|
@ -21,7 +21,7 @@ LOG = logging.getLogger(__name__)
|
||||
|
||||
DEFAULT_QUEUES_API_VERSION = '1'
|
||||
API_VERSION_OPTION = 'os_queues_api_version'
|
||||
API_NAME = "queuing"
|
||||
API_NAME = "messaging"
|
||||
API_VERSIONS = {
|
||||
"1": "zaqarclient.queues.v1.client.Client",
|
||||
}
|
||||
|
@ -63,7 +63,7 @@ class DeleteQueue(command.Command):
|
||||
|
||||
def take_action(self, 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
|
||||
|
||||
@ -91,7 +91,7 @@ class ListQueues(lister.Lister):
|
||||
def take_action(self, parsed_args):
|
||||
self.log.debug("take_action(%s)" % parsed_args)
|
||||
|
||||
client = self.app.client_manager.queuing
|
||||
client = self.app.client_manager.messaging
|
||||
|
||||
kwargs = {}
|
||||
if parsed_args.marker is not None:
|
||||
@ -122,7 +122,7 @@ class CheckQueueExistence(show.ShowOne):
|
||||
def take_action(self, 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 = client.queue(queue_name, auto_create=False)
|
||||
@ -152,7 +152,7 @@ class SetQueueMetadata(command.Command):
|
||||
def take_action(self, 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_metadata = parsed_args.queue_metadata
|
||||
@ -187,7 +187,7 @@ class GetQueueMetadata(show.ShowOne):
|
||||
def take_action(self, 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 = client.queue(queue_name, auto_create=False)
|
||||
@ -216,7 +216,7 @@ class GetQueueStats(show.ShowOne):
|
||||
def take_action(self, 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 = client.queue(queue_name, auto_create=False)
|
||||
|
Loading…
x
Reference in New Issue
Block a user