)]}'
{"oslo_messaging/_drivers/amqpdriver.py":[{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"5bfd660d53033d1c44622766c1e67c5d325b0be4","unresolved":false,"context_lines":[{"line_number":202,"context_line":"                              \"retrying...\")"},{"line_number":203,"context_line":""},{"line_number":204,"context_line":"    def process_incoming(self):"},{"line_number":205,"context_line":"        while self.incoming:"},{"line_number":206,"context_line":"            message_data \u003d self.incoming.pop(0)"},{"line_number":207,"context_line":"            incoming_msg_id \u003d message_data.pop(\u0027_msg_id\u0027, None)"},{"line_number":208,"context_line":"            self.waiters.put(incoming_msg_id, message_data)"}],"source_content_type":"text/x-python","patch_set":5,"id":"1a930d6b_213d4c90","line":205,"updated":"2015-01-21 23:51:02.000000000","message":"Should this consume up to X messages (just an idea); that way the conn.consume will always be called after X messages instead of maybe being delayed. Just an idea; may not be that useful/needed :-P","commit_id":"2f82f510365073d4739f2816a561340f8dc1e2d6"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"adf1595342a3f37c203ccb4ecff406bdda4ef5c8","unresolved":false,"context_lines":[{"line_number":202,"context_line":"                              \"retrying...\")"},{"line_number":203,"context_line":""},{"line_number":204,"context_line":"    def process_incoming(self):"},{"line_number":205,"context_line":"        while self.incoming:"},{"line_number":206,"context_line":"            message_data \u003d self.incoming.pop(0)"},{"line_number":207,"context_line":"            incoming_msg_id \u003d message_data.pop(\u0027_msg_id\u0027, None)"},{"line_number":208,"context_line":"            self.waiters.put(incoming_msg_id, message_data)"}],"source_content_type":"text/x-python","patch_set":5,"id":"1a930d6b_0364cbb7","line":205,"in_reply_to":"1a930d6b_213d4c90","updated":"2015-01-22 08:51:19.000000000","message":"I have removed this code, we don\u0027t need this intermediate queue anymore, now we can directly move the incoming message to the queue of application thread.","commit_id":"2f82f510365073d4739f2816a561340f8dc1e2d6"},{"author":{"_account_id":8415,"name":"Denis M.","email":"lildee1991@gmail.com","username":"dmakogon"},"change_message_id":"b98e39f925751cdc1a3d58f25223ebc9cec158f8","unresolved":false,"context_lines":[{"line_number":195,"context_line":"            try:"},{"line_number":196,"context_line":"                self.conn.consume(limit\u003d1)"},{"line_number":197,"context_line":"            except Exception:"},{"line_number":198,"context_line":"                LOG.exception(\"Failed to process incoming message, \""},{"line_number":199,"context_line":"                              \"retrying...\")"},{"line_number":200,"context_line":""},{"line_number":201,"context_line":"    def __call__(self, message):"}],"source_content_type":"text/x-python","patch_set":6,"id":"1a930d6b_3b1e3a64","line":198,"updated":"2015-01-22 16:21:14.000000000","message":"please use i18n wrappers","commit_id":"9e36c03352eb56202429d521fc125bac5eb23722"}]}