def call(self, n):
        self.response = None
        self.corr_id = str(uuid.uuid4())
        msg = Message(str(n), reply_to=self.callback_queue, correlation_id=self.corr_id)
        self.channel.basic.publish(msg, '', 'rpc_queue')
        while self.response is None:
            self.connection.read_frames()
        return int(self.response)
dataset/ETHPy150Open agoragames/haigha/examples/rpc_client.py/FibonacciRpcClient.call/original