openstack
/
oslo.messaging
Code Issues Proposed changes

Trivial: Add executor 'threading' in docstring 

oslo.messaging supports three types of executors: blocking, eventlet
and threading, so it's good to list all of them in docstring.

Change-Id: Ief14d54b5f029cf3e9c79334e405dca5cf2dc13d
This commit is contained in:
ChangBo Guo(gcb) 2017-03-20 17:24:32 +08:00
parent 2ee6a2a480
commit abc269b7e5
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
oslo_messaging/notify/listener.py
View File

@ -225,8 +225,8 @@ def get_notification_listener(transport, targets, endpoints,
:type targets: list of Target
:param endpoints: a list of endpoint objects
:type endpoints: list
:param executor: name of a message executor - for example
'eventlet', 'blocking'
:param executor: name of message executor - available values are
'eventlet', 'blocking' and 'threading'
:type executor: str
:param serializer: an optional entity serializer
:type serializer: Serializer
@ -261,8 +261,8 @@ def get_batch_notification_listener(transport, targets, endpoints,
:type targets: list of Target
:param endpoints: a list of endpoint objects
:type endpoints: list
:param executor: name of a message executor - for example
'eventlet', 'blocking'
:param executor: name of message executor - available values are
'eventlet', 'blocking' and 'threading'
:type executor: str
:param serializer: an optional entity serializer
:type serializer: Serializer

4
oslo_messaging/rpc/server.py
View File

@ -198,8 +198,8 @@ def get_rpc_server(transport, target, endpoints,
:type target: Target
:param endpoints: a list of endpoint objects
:type endpoints: list
:param executor: name of a message executor - for example
'eventlet', 'blocking'
:param executor: name of message executor - available values are
'eventlet', 'blocking' and 'threading'
:type executor: str
:param serializer: an optional entity serializer
:type serializer: Serializer

4
oslo_messaging/server.py
View File

@ -321,8 +321,8 @@ class MessageHandlingServer(service.ServiceBase, _OrderedTaskRunner):
:param dispatcher: has a dispatch() method which is invoked for each
incoming request
:type dispatcher: DispatcherBase
:param executor: name of message executor - for example
'eventlet', 'blocking'
:param executor: name of message executor - available values are
'eventlet', 'blocking' and 'threading'
:type executor: str
"""
self.conf = transport.conf