Code Review
/
yardstick.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add JS file to NSB report template
[yardstick.git]
/
yardstick
/
common
/
messaging
/
consumer.py
diff --git
a/yardstick/common/messaging/consumer.py
b/yardstick/common/messaging/consumer.py
index
a0feeb3
..
7ce9bda
100644
(file)
--- a/
yardstick/common/messaging/consumer.py
+++ b/
yardstick/common/messaging/consumer.py
@@
-29,9
+29,10
@@
LOG = logging.getLogger(__name__)
class NotificationHandler(object):
"""Abstract class to define a endpoint object for a MessagingConsumer"""
class NotificationHandler(object):
"""Abstract class to define a endpoint object for a MessagingConsumer"""
- def __init__(self, id, ctx_pid, queue):
- self._id = id
- self._ctx_pid = ctx_pid
+ def __init__(self, _id, ctx_ids, queue):
+ super(NotificationHandler, self).__init__()
+ self._id = _id
+ self._ctx_ids = ctx_ids
self._queue = queue
self._queue = queue
@@
-43,12
+44,12
@@
class MessagingConsumer(object):
the messages published by a `MessagingNotifier`.
"""
the messages published by a `MessagingNotifier`.
"""
- def __init__(self, topic,
pid
, endpoints, fanout=True):
+ def __init__(self, topic,
ids
, endpoints, fanout=True):
"""Init function.
:param topic: (string) MQ exchange topic
"""Init function.
:param topic: (string) MQ exchange topic
- :param
pid: (int) PID of the process implementing the MQ Notifier which
- will be in the message context
+ :param
ids: (list of int) list of IDs of the processes implementing
+
the MQ Notifier which
will be in the message context
:param endpoints: (list of class) list of classes implementing the
methods (see `MessagingNotifier.send_message) used by
the Notifier
:param endpoints: (list of class) list of classes implementing the
methods (see `MessagingNotifier.send_message) used by
the Notifier
@@
-58,7
+59,7
@@
class MessagingConsumer(object):
:returns: `MessagingConsumer` class object
"""
:returns: `MessagingConsumer` class object
"""
- self._
pid = pid
+ self._
ids = ids
self._endpoints = endpoints
self._transport = oslo_messaging.get_rpc_transport(
cfg.CONF, url=messaging.TRANSPORT_URL)
self._endpoints = endpoints
self._transport = oslo_messaging.get_rpc_transport(
cfg.CONF, url=messaging.TRANSPORT_URL)