openstack/oslo.messaging
Code Issues Proposed changes

Merge "Doc: 'wait' releases driver connection, not 'stop'"

Browse Source
This commit is contained in:
Jenkins 2014-12-09 11:59:05 +00:00 committed by Gerrit Code Review
commit 836f16f3fe
1 changed files with 5 additions and 1 deletions

6
oslo/messaging/server.py

@ -126,7 +126,8 @@ class MessageHandlingServer(object):
Once this method returns, no new incoming messages will be handled by Once this method returns, no new incoming messages will be handled by
the server. However, the server may still be in the process of handling the server. However, the server may still be in the process of handling
some messages. some messages, and underlying driver resources associated to this
server are still in use. See 'wait' for more details.
""" """
if self._executor is not None: if self._executor is not None:
self._executor.stop() self._executor.stop()
@ -137,6 +138,9 @@ class MessageHandlingServer(object):
After calling stop(), there may still be some some existing messages After calling stop(), there may still be some some existing messages
which have not been completely processed. The wait() method blocks which have not been completely processed. The wait() method blocks
until all message processing has completed. until all message processing has completed.
Once it's finished, the underlying driver resources associated to this
server are released (like closing useless network connections).
""" """
if self._executor is not None: if self._executor is not None:
self._executor.wait() self._executor.wait()