Merge pull request #325 from ChamRun/python_loop_fix

Python loop fix

Author: michaelklishin

python/rpc_client.py

@@ -19,6 +19,9 @@ def __init__(self):
             on_message_callback=self.on_response,
             auto_ack=True)
 
+        self.response = None
+        self.corr_id = None
+
     def on_response(self, ch, method, props, body):
         if self.corr_id == props.correlation_id:
             self.response = body
@@ -34,8 +37,7 @@ def call(self, n):
                 correlation_id=self.corr_id,
             ),
             body=str(n))
-        while self.response is None:
-            self.connection.process_data_events()
+        self.connection.process_data_events(time_limit=None)
         return int(self.response)