x/deb-oslo.messaging
Code Issues Proposed changes

Merge "batch notification listener"

Browse Source
This commit is contained in:
Jenkins
2015-12-11 04:16:57 +00:00
committed by Gerrit Code Review
parent 4b6144a3db 4dd644ac20
commit 213176657d
25 changed files with 450 additions and 127 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
oslo_messaging/rpc/dispatcher.py
View File

@@ -131,9 +131,9 @@ class RPCDispatcher(dispatcher.DispatcherBase):
return self.serializer.serialize_entity(ctxt, result)
def __call__(self, incoming, executor_callback=None):
incoming.acknowledge()
incoming[0].acknowledge()
return dispatcher.DispatcherExecutorContext(
incoming, self._dispatch_and_reply,
incoming[0], self._dispatch_and_reply,
executor_callback=executor_callback)
def _dispatch_and_reply(self, incoming, executor_callback):