Commit 9f55f379 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Replaced 'id' with 'req_id'. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban.slack@gmail.com>
parent a02ee6ad

client/redis_rpc_client.py

+1 −1
Original line number Diff line number Diff line
@@ -10,7 +10,7 @@ class RedisRPCClient(object): 


    def call(self, request):

        requestId = uuid.uuid1().hex

        request["id"] = requestId

        request["req_id"] = requestId

        self.client.lpush(self.rpcQueue, json.dumps(request))

        channel, response = self.client.brpop(requestId, timeout = 30)

        response = json.loads(response.decode("utf-8"))

transfer_service/redis_rpc_server.py

+2 −2
Original line number Diff line number Diff line
@@ -17,8 +17,8 @@ class RedisRPCServer(threading.Thread): 
            channel = channel.decode("utf-8")

            request = json.loads(request.decode("utf-8"))

            response = self.callback(request)

            self.client.rpush(request["id"], json.dumps(response))

            self.client.expire(request["id"], 30)

            self.client.rpush(request["req_id"], json.dumps(response))

            self.client.expire(request["req_id"], 30)



    def callback(self, request):

        """