openstack
/
oslo.messaging
Code Issues Proposed changes

Merge "Fix some reST field lists in docstrings"

This commit is contained in:
Jenkins 2017-09-08 05:07:28 +00:00 committed by Gerrit Code Review
parent 338b85eb4e d7229a124f
commit 809d4a54f1
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
oslo_messaging/_drivers/pika_driver/pika_message.py
View File

@ -180,7 +180,7 @@ class RpcPikaIncomingMessage(PikaIncomingMessage, base.RpcIncomingMessage):
:param failure: Tuple, should be a sys.exc_info() tuple.
Should be None if RPC request was successfully processed.
:return RpcReplyPikaIncomingMessage, message with reply
:return RpcReplyPikaIncomingMessage: message with reply
"""
if self.reply_q is None:

8
oslo_messaging/_drivers/pika_driver/pika_poller.py
View File

@ -218,7 +218,7 @@ class PikaPoller(base.Listener):
exchange and (or) queue do not exist. Should be overridden in child
classes
:return Dictionary, declared_queue_name -> no_ack_mode
:return Dictionary: declared_queue_name -> no_ack_mode
"""
raise NotImplementedError(
"It is base class. Please declare exchanges and queues here"
@ -377,7 +377,7 @@ class RpcServicePikaPoller(PikaPoller):
"""Overrides base method and perform declaration of RabbitMQ exchanges
and queues which correspond to oslo.messaging RPC target
:return Dictionary, declared_queue_name -> no_ack_mode
:return Dictionary: declared_queue_name -> no_ack_mode
"""
queue_expiration = self._pika_engine.rpc_queue_expiration
@ -465,7 +465,7 @@ class RpcReplyPikaPoller(PikaPoller):
"""Overrides base method and perform declaration of RabbitMQ exchange
and queue used for RPC reply delivery
:return Dictionary, declared_queue_name -> no_ack_mode
:return Dictionary: declared_queue_name -> no_ack_mode
"""
self._pika_engine.declare_queue_binding_by_channel(
channel=self._channel,
@ -513,7 +513,7 @@ class NotificationPikaPoller(PikaPoller):
"""Overrides base method and perform declaration of RabbitMQ exchanges
and queues used for notification delivery
:return Dictionary, declared_queue_name -> no_ack_mode
:return Dictionary: declared_queue_name -> no_ack_mode
"""
queues_to_consume = []
for target, priority in self._targets_and_priorities: