Temporary fix for bad _dispatch() invocation

This fixes the incorrect arguments passed to _dispatch(), now that the
method signature is changing in oslo.messaging. The code should be
further updated to not use a private method of the base class.

Change-Id: I2d72a687925122e1106c031df256dff4278dca5b
Partial-bug: #1412977
This commit is contained in:
Doug Hellmann 2015-01-20 22:07:34 +00:00
parent c5ec416b7a
commit a86181a9fe

View File

@ -173,9 +173,9 @@ class RequestContextSerializer(messaging.Serializer):
class RPCDispatcher(rpc_dispatcher.RPCDispatcher): class RPCDispatcher(rpc_dispatcher.RPCDispatcher):
def _dispatch(self, ctxt, message): def _dispatch(self, *args, **kwds):
try: try:
return super(RPCDispatcher, self)._dispatch(ctxt, message) return super(RPCDispatcher, self)._dispatch(*args, **kwds)
except Exception as e: except Exception as e:
if getattr(e, 'expected', False): if getattr(e, 'expected', False):
raise rpc_dispatcher.ExpectedException() raise rpc_dispatcher.ExpectedException()