From e40f6398f9948adfe3657cd935b2dc02523f211f Mon Sep 17 00:00:00 2001 From: zhangshengping2012 Date: Wed, 26 Oct 2016 12:19:51 +0800 Subject: [PATCH] Remove the temporary hack in code remove the temporary hack in code amqpdriver.py Change-Id: I7ba9666fc15a6fc4ab27b04362e94661c00547c5 --- oslo_messaging/_drivers/amqpdriver.py | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) diff --git a/oslo_messaging/_drivers/amqpdriver.py b/oslo_messaging/_drivers/amqpdriver.py index 5668b0371..c0eec3f43 100644 --- a/oslo_messaging/_drivers/amqpdriver.py +++ b/oslo_messaging/_drivers/amqpdriver.py @@ -394,15 +394,6 @@ class AMQPDriverBase(base.BaseDriver): wait_for_reply=None, timeout=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 if wait_for_reply: @@ -413,7 +404,7 @@ class AMQPDriverBase(base.BaseDriver): rpc_amqp._add_unique_id(msg) unique_id = msg[rpc_amqp.UNIQUE_ID] - rpc_amqp.pack_context(msg, context) + rpc_amqp.pack_context(msg, ctxt) if envelope: msg = rpc_common.serialize_msg(msg)