)]}'
{"oslo_messaging/_drivers/impl_rabbit.py":[{"author":{"_account_id":6537,"name":"gordon chung","email":"gord@live.ca","username":"chungg"},"change_message_id":"58ca4c8681d34a7133f0666537cf2d07a4c5fb5e","unresolved":false,"context_lines":[{"line_number":224,"context_line":""},{"line_number":225,"context_line":"    def consume(self, *args, **kwargs):"},{"line_number":226,"context_line":"        \"\"\"Actually declare the consumer on the amqp channel.  This will"},{"line_number":227,"context_line":"        start the flow of messages from the queue.  Using the"},{"line_number":228,"context_line":"        Connection.iterconsume() iterator will process the messages,"},{"line_number":229,"context_line":"        calling the appropriate callback."},{"line_number":230,"context_line":""}],"source_content_type":"text/x-python","patch_set":4,"id":"3acd31a7_d7120c62","line":227,"updated":"2015-05-01 18:53:48.000000000","message":"update doc","commit_id":"2341f3225c7c8bfd45be8b7335ec3d1cd55ee8f6"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"dfa0b5a90fcb55524ca768c44bc4d374ba6c88ce","unresolved":false,"context_lines":[{"line_number":224,"context_line":""},{"line_number":225,"context_line":"    def consume(self, *args, **kwargs):"},{"line_number":226,"context_line":"        \"\"\"Actually declare the consumer on the amqp channel.  This will"},{"line_number":227,"context_line":"        start the flow of messages from the queue.  Using the"},{"line_number":228,"context_line":"        Connection.iterconsume() iterator will process the messages,"},{"line_number":229,"context_line":"        calling the appropriate callback."},{"line_number":230,"context_line":""}],"source_content_type":"text/x-python","patch_set":4,"id":"3acd31a7_5d1048a8","line":227,"in_reply_to":"3acd31a7_d7120c62","updated":"2015-05-04 06:42:11.000000000","message":"Done","commit_id":"2341f3225c7c8bfd45be8b7335ec3d1cd55ee8f6"},{"author":{"_account_id":6537,"name":"gordon chung","email":"gord@live.ca","username":"chungg"},"change_message_id":"58ca4c8681d34a7133f0666537cf2d07a4c5fb5e","unresolved":false,"context_lines":[{"line_number":1035,"context_line":"        with self._connection_lock:"},{"line_number":1036,"context_line":"            for iteration in itertools.count(0):"},{"line_number":1037,"context_line":"                if (self._consume_loop_stopped or"},{"line_number":1038,"context_line":"                        (limit and iteration \u003e\u003d limit)):"},{"line_number":1039,"context_line":"                    self._consume_loop_stopped \u003d False"},{"line_number":1040,"context_line":"                    return"},{"line_number":1041,"context_line":""}],"source_content_type":"text/x-python","patch_set":4,"id":"3acd31a7_629ff850","line":1038,"updated":"2015-05-01 18:53:48.000000000","message":"whats the difference between this limit and the retry parameter in ensure?","commit_id":"2341f3225c7c8bfd45be8b7335ec3d1cd55ee8f6"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"dfa0b5a90fcb55524ca768c44bc4d374ba6c88ce","unresolved":false,"context_lines":[{"line_number":1035,"context_line":"        with self._connection_lock:"},{"line_number":1036,"context_line":"            for iteration in itertools.count(0):"},{"line_number":1037,"context_line":"                if (self._consume_loop_stopped or"},{"line_number":1038,"context_line":"                        (limit and iteration \u003e\u003d limit)):"},{"line_number":1039,"context_line":"                    self._consume_loop_stopped \u003d False"},{"line_number":1040,"context_line":"                    return"},{"line_number":1041,"context_line":""}],"source_content_type":"text/x-python","patch_set":4,"id":"3acd31a7_3d56ac5c","line":1038,"in_reply_to":"3acd31a7_629ff850","updated":"2015-05-04 06:42:11.000000000","message":"limit is the number of event to read from the broker, I will remove it in further patch this is always set to 1...\n\nretry is the number of times we try to connect to the broker (in case of transport failure) before returning to the application.","commit_id":"2341f3225c7c8bfd45be8b7335ec3d1cd55ee8f6"}]}