diff --git a/utils/broker.py b/utils/broker.py index 99e6bff..853e88e 100644 --- a/utils/broker.py +++ b/utils/broker.py @@ -103,10 +103,7 @@ def handle_request(requet_bytes, handler): } response = handler(envirnment) - print(response.content) - # print(response.data) - print(dir(response)) - # print(views.TestApiView().dispatch(request).data) + # print(response.content) return response @@ -130,7 +127,7 @@ def get_rpc_broker_consumer(): exchange="", routing_key=props.reply_to, properties=pika.BasicProperties(correlation_id=props.correlation_id), - body=str(response.content), + body=response.content, ) ch.basic_ack(delivery_tag=method.delivery_tag) diff --git a/utils/rpc_client.py b/utils/rpc_client.py index a3976e2..b1bb4b2 100644 --- a/utils/rpc_client.py +++ b/utils/rpc_client.py @@ -62,5 +62,8 @@ request = Request(method=method, url=url, json={'key_1': 'requests_lib'}) rpc = RpcClient() print(" [x] Requesting ...") -response = rpc.call(request) -print(response) \ No newline at end of file +for i in range(1000): + response = rpc.call(request) + # print(response.decode()) + # print(type(response.decode())) + print(i) \ No newline at end of file