diff options
Diffstat (limited to 'oslo_messaging/_drivers/zmq_driver/rpc/client/zmq_request.py')
-rw-r--r-- | oslo_messaging/_drivers/zmq_driver/rpc/client/zmq_request.py | 14 |
1 files changed, 1 insertions, 13 deletions
diff --git a/oslo_messaging/_drivers/zmq_driver/rpc/client/zmq_request.py b/oslo_messaging/_drivers/zmq_driver/rpc/client/zmq_request.py index 88a4f85..b06699d 100644 --- a/oslo_messaging/_drivers/zmq_driver/rpc/client/zmq_request.py +++ b/oslo_messaging/_drivers/zmq_driver/rpc/client/zmq_request.py @@ -13,9 +13,7 @@ # under the License. import abc -from abc import abstractmethod import logging -import uuid import six @@ -42,7 +40,6 @@ class Request(object): LOG.error(errmsg) raise KeyError(errmsg) - self.msg_id = uuid.uuid4().hex self.target = target self.context = context self.message = message @@ -55,17 +52,8 @@ class Request(object): def msg_type(self): """ZMQ message type""" - @property - def is_replied(self): - return self.reply is not None - - @property - def is_timed_out(self): - return False - def send_request(self): self.socket.send_string(self.msg_type, zmq.SNDMORE) - self.socket.send_json(self.target.__dict__, zmq.SNDMORE) self.socket.send_json(self.context, zmq.SNDMORE) self.socket.send_json(self.message) @@ -73,6 +61,6 @@ class Request(object): self.send_request() return self.receive_reply() - @abstractmethod + @abc.abstractmethod def receive_reply(self): "Receive reply from server side" |