"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "zaqar/storage/pooling.py" between
zaqar-9.0.0.tar.gz and zaqar-10.0.0.tar.gz

About: OpenStack Zaqar is a multi-tenant cloud messaging and notification service for web and mobile developers.
The "Ussuri" series (latest release).

pooling.py  (zaqar-9.0.0):pooling.py  (zaqar-10.0.0)
skipping to change at line 263 skipping to change at line 263
return self._mgt_queue_ctrl.set_metadata(name, metadata=metadata, return self._mgt_queue_ctrl.set_metadata(name, metadata=metadata,
project=project) project=project)
def _stats(self, name, project=None): def _stats(self, name, project=None):
mqHandler = self._get_controller(name, project) mqHandler = self._get_controller(name, project)
if mqHandler: if mqHandler:
return mqHandler.stats(name, project=project) return mqHandler.stats(name, project=project)
raise errors.QueueDoesNotExist(name, project) raise errors.QueueDoesNotExist(name, project)
def _calculate_resource_count(self, project=None):
return self._mgt_queue_ctrl.calculate_resource_count(project=project)
class MessageController(storage.Message): class MessageController(storage.Message):
"""Routes operations to a message controller in the appropriate pool. """Routes operations to a message controller in the appropriate pool.
:param pool_catalog: a catalog of available pools :param pool_catalog: a catalog of available pools
:type pool_catalog: queues.pooling.base.Catalog :type pool_catalog: queues.pooling.base.Catalog
""" """
def __init__(self, pool_catalog): def __init__(self, pool_catalog):
super(MessageController, self).__init__(None) super(MessageController, self).__init__(None)
self._pool_catalog = pool_catalog self._pool_catalog = pool_catalog
 End of changes. 1 change blocks. 
0 lines changed or deleted 3 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)