openstack/oslo.messaging
Code Issues Proposed changes

Merge "Remove the temporary hack in code"

Browse Source
This commit is contained in:
Jenkins 2016-11-04 22:20:10 +00:00 committed by Gerrit Code Review
commit dd99f7b1e6
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
oslo_messaging/_drivers/amqpdriver.py
View File

@ -394,15 +394,6 @@ class AMQPDriverBase(base.BaseDriver):
wait_for_reply=None, timeout=None, wait_for_reply=None, timeout=None,
envelope=True, notify=False, retry=None): envelope=True, notify=False, retry=None):
# FIXME(markmc): remove this temporary hack
class Context(object):
def __init__(self, d):
self.d = d
def to_dict(self):
return self.d
context = Context(ctxt)
msg = message msg = message
if wait_for_reply: if wait_for_reply:
@ -413,7 +404,7 @@ class AMQPDriverBase(base.BaseDriver):
rpc_amqp._add_unique_id(msg) rpc_amqp._add_unique_id(msg)
unique_id = msg[rpc_amqp.UNIQUE_ID] unique_id = msg[rpc_amqp.UNIQUE_ID]
rpc_amqp.pack_context(msg, context) rpc_amqp.pack_context(msg, ctxt)
if envelope: if envelope:
msg = rpc_common.serialize_msg(msg) msg = rpc_common.serialize_msg(msg)